Search before asking
Version
pulsar 2.9.2
Minimal reproduce step
- Create a topic with 1 partitions, send traffic normally
- start two consumer process instance in Shared mode
- One process calls
acknowledge after normal consumption
- Another process delays calling
acknowledge with Thread.sleep(100000L) after consumption
- After a while,
resetCursor("persistent://chenjianbo-tenant1/chenjianbo-ns/test111","subscription1", System.currentTimeMillis() - 5 * 60 * 1000), but the getPublishTime of received message of the first process is 1 hour ago.
What did you expect to see?
getPublishTime is the correct time
What did you see instead?
after resetCursor , the first process returns the earliest data of the topic
Anything else?
I found this problem occur when searchPosition and getLastPosition is equals, and individualDeletedMessages is not empty at the same time
Are you willing to submit a PR?
Search before asking
Version
pulsar 2.9.2
Minimal reproduce step
acknowledgeafter normal consumptionacknowledgewithThread.sleep(100000L)after consumptionresetCursor("persistent://chenjianbo-tenant1/chenjianbo-ns/test111","subscription1", System.currentTimeMillis() - 5 * 60 * 1000), but the getPublishTime of received message of the first process is 1 hour ago.What did you expect to see?
getPublishTime is the correct time
What did you see instead?
after resetCursor , the first process returns the earliest data of the topic
Anything else?
I found this problem occur when
searchPositionandgetLastPositionis equals, andindividualDeletedMessagesis not empty at the same timeAre you willing to submit a PR?