yjshen commented on a change in pull request #6345: [Java Reader Client] Start
reader inside batch result in read first message in batch.
URL: https://github.com/apache/pulsar/pull/6345#discussion_r382903005
##########
File path:
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java
##########
@@ -122,6 +123,9 @@
private final SubscriptionMode subscriptionMode;
private volatile BatchMessageIdImpl startMessageId;
+ private volatile BatchMessageIdImpl seekMessageId;
+ private final AtomicBoolean duringSeek;
Review comment:
I don't think so. Without the flag, we cannot tell if seekMessageId or
lastDequeueMessage should be used as the start message id.
----------------------------------------------------------------
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]
With regards,
Apache Git Services
