zhangzhencx opened a new issue #2422:
URL: https://github.com/apache/rocketmq/issues/2422
From the logs ,can know as this.
the consume client can consume the latest message ,like queueid = 3 offset =
18305, but commited offset is stopped at 17448.
2020-11-12 08:27:37,037 INFO RocketmqClient - [persistAll] Group:
CrawlVideoAsyncEventConsumer1 ClientId: 172.18.0.1@104940
updateConsumeOffsetToBroker MessageQueue [topic=TempDetectionOfVideo,
brokerName=broker-a, queueId=3] 17448
the consume client print "**grab msg queueId = 3 offset = 18305"
public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs,
ConsumeConcurrentlyContext context) {
for (int i = 0; i < msgs.size(); i++) {
log.info("grab msg queueId = " +
msgs.get(i).getQueueId()+" offset = "+msgs.get(i).getQueueOffset());}
----------------------------------------------------------------
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]
