You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I searched in the issues and found nothing similar.
What issue do you find in Pulsar docs?
/** * Set the reader to include the given position of {@link ReaderBuilder#startMessageId(MessageId)} * * <p>This configuration option also applies for any cursor reset operation like {@link Reader#seek(MessageId)}. * * @return the reader builder instance */ReaderBuilder<T> startMessageIdInclusive();
/** * Sets the consumer to include the given position of any reset operation like {@link Consumer#seek(long)} or * {@link Consumer#seek(MessageId)}}. * * @return the consumer builder instance */ConsumerBuilder<T> startMessageIdInclusive();
The ReaderBuilder#startMessageIdInclusive and ConsumerBuilder#startMessageIdInclusive method comments said Sets the consumer to include the given position of any reset operation like {@link Consumer#seek(long)} or * {@link Consumer#seek(MessageId)}}..
But I found that Consumer#seek(long) will contain the firstMessageId regardless of whether startMessageIdInclusive is present or not, the Consumer#seek(long) and startMessageIdInclusive have no relation
What is your suggestion?
remove the Consumer#seek(long) in comment of ReaderBuilder#startMessageIdInclusive and ConsumerBuilder#startMessageIdInclusive
Any reference?
No response
Are you willing to submit a PR?
I'm willing to submit a PR!
The text was updated successfully, but these errors were encountered:
Search before asking
What issue do you find in Pulsar docs?
The ReaderBuilder#startMessageIdInclusive and ConsumerBuilder#startMessageIdInclusive method comments said
Sets the consumer to include the given position of any reset operation like {@link Consumer#seek(long)} or * {@link Consumer#seek(MessageId)}}.
.But I found that Consumer#seek(long) will contain the firstMessageId regardless of whether startMessageIdInclusive is present or not, the
Consumer#seek(long)
andstartMessageIdInclusive
have no relationWhat is your suggestion?
remove the Consumer#seek(long) in comment of ReaderBuilder#startMessageIdInclusive and ConsumerBuilder#startMessageIdInclusive
Any reference?
No response
Are you willing to submit a PR?
The text was updated successfully, but these errors were encountered: