question 1:after return true when consumed, the message will never comes to you again unless commit fail.
question 2: rocketmq has two ways of consuming: cluster and broadcast.
i.e: 2 consumer instances, 100 messages sent,
for cluster: 50 for consumer instance 1, another 50 for consumer instance 2
for broadcast: 100 for consumer instance 1, same 100 for consumer instance 2
Tiger Lee
- reputation score 13
- 4 bronze badges