[GitHub] [rocketmq] francisoliverlee commented on issue #2584: Which method can consume a message with a message ID

[GitBox <gi...@apache.org>]

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:
users@infra.apache.org