search

apache / rocketmq-streams

Apache rocketmq
https://rocketmq.apache.org/
Apache License 2.0
171 stars 82 forks source link

Adjust RSQLDB #253

Closed ni-ze closed 1 year ago

ni-ze commented 1 year ago
  1. use normal topic as state topic, replace compact-static topic;
  2. add isRunning method in RocketMQStream.