francisoliverlee commented on issue #2584: URL: https://github.com/apache/rocketmq/issues/2584#issuecomment-758351537
@allnameshasbeensignup 1. when consuming, message id is in MessageExt, check the code bellow: https://github.com/apache/rocketmq/blob/39bb9386f10d5d8dfe81183c172a3a86f6d313bd/common/src/main/java/org/apache/rocketmq/common/message/MessageExt.java#L27-L48 2. it seems the ways of consuming is not right. check following 2 options - make sure all consumer instances must substribe the same topics with tags. [reference aliyun doc](https://help.aliyun.com/document_detail/43523.html?spm=5176.10695662.1996646101.searchclickresult.485c273bEDTfai) eg: a consumer group named consumerGroupA subscribe topicA, and the app with consumerGroupA deployed on 4 server: s1, s2, s3, s4. RIGHT Subscription: ``` s1: consumerGroupA sub topicA s2: consumerGroupA sub topicA s3: consumerGroupA sub topicA s4: consumerGroupA sub topicA ``` WRONG Subscription: ``` s1: consumerGroupA sub topicA, tagA s2: consumerGroupA sub topicA s3: consumerGroupA sub topicA s4: consumerGroupA sub topicA ``` - if run in Docker, make sure every consumer instance has different instance name ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected]
