|Constructor and Description|
|Modifier and Type||Method and Description|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public MessageIdStartCursor(org.apache.pulsar.client.api.MessageId messageId, boolean inclusive)
inclusivebehavior should be controlled in
ConsumerBuilder.startMessageIdInclusive(). But pulsar has a bug and don't support this currently. We have to use
entry + 1policy for consuming the next available message. If the message id entry is not valid. Pulsar would automatically find next valid message id. Please referer this code for understanding pulsar internal logic.
messageId- The message id for start position.
inclusive- Should we include the start message id in consuming result.
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.