qsrg commented on issue #2477: URL: https://github.com/apache/rocketmq/issues/2477#issuecomment-738533078
@francisoliverlee no error log, just the allocate result is wrong. **This causes consumer consumed messages not in consumeridcs.** reproduce step: 1. new a DefaultMQPushConsumer 2. new a AllocateMessageQueueByMachineRoom, and config consumeridcs 3. set consumer's allocateMessageQueueStrategy to AllocateMessageQueueByMachineRoom 4. subscribe a topic and start consumer。 BTW，your broker name should follow the naming style "idc@brokername", as AllocateMessageQueueByMachineRoom will split by "@" to get idc. Otherwise you can write code to get your idc rightly. ---------------------------------------------------------------- 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]
