Tag: rocketmq

After send message to the RocketMQ 4.8, I found the consumer only consumed part of the queue. This is the RocketMQ consumer code looks like: When I access to the RocketMQ dashboard, I found the consumer only consumed part of the queue in the same broker: The queue 0 and 1’s message were not consumed by the consumer. Why did

I am using RocketMQ as the message center, this is the consumer dependencies jar: this is part of the conumser code: in this code block, I want to get the consumerGroup name, I tracing into the ConsumeConcurrentlyContext class and only found the topic, did not found the consumerGroup name. is it possible to get the consumerGroup name from the registerMessageListener