RocketMQ5.1.1 version is not compatible: when querying messages, it displays that each message will be repeated
Opened this issue · 1 comments
charlienss commented
RocketMQ5.1.1 version is not compatible: when querying messages, it displays that each message will be repeated
charlienss commented
The problem with duplicate queries is the source code of the dashboard, which may be caused by incompatibility after version 5.1.1. It is recommended to manually change the source code:
Org. apache. locketmq. dashboard. service. impl. Message Service Impl # queryFirstMessage Page
Line 271 should read:
Long maxOffset=consumer. searchOffset (messageQueue, query. getEnd());