1. use normal topic as state topic, replace compact-static topic; 2. add isRunning method in RocketMQStream.