longbowen commented on issue #287:
URL:
https://github.com/apache/rocketmq-streams/issues/287#issuecomment-1534172770
spring boot
整合rocketmq中的消费者组。比如device-property-change-topic这个topic会被服务A与服务B消费，但是服务A与服务B是不同的分组。集群消费模式下，会被服务A与服务B同时消费。
在我的场景中，服务A正常运行，服务B未启动。此时发送消息message1-10。
服务A正常消费数据message1-message10，此时启动服务B。同时服务B启动时会初始化rocketmq-stream，
此时服务B消费message1-10之前，rocket-stream也会处理message1-10。
以下配置中的group
举例：
spring:
cloud:
stream:
bindings:
device-property-change-input:
destination: device-property-change-topic
content-type: application/json
group: device-property-change-group #消费者组
consumer.concurrency: 10
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
