org.apache.flink.connector.pulsar.source.enumerator.cursor.start

Class MessageIdStartCursor

java.lang.Object

org.apache.flink.connector.pulsar.source.enumerator.cursor.start.MessageIdStartCursor

All Implemented Interfaces:

Serializable, StartCursor

public class MessageIdStartCursor
extends Object
implements StartCursor

This cursor would leave pulsar start consuming from a specific message id.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
MessageIdStartCursor(org.apache.pulsar.client.api.MessageId messageId, boolean inclusive) The default inclusive behavior should be controlled in ConsumerBuilder.startMessageIdInclusive().

Method Summary

Modifier and Type	Method and Description
CursorPosition	position(String topic, int partitionId)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.connector.pulsar.source.enumerator.cursor.StartCursor

defaultStartCursor, earliest, fromMessageId, fromMessageId, fromMessageTime, fromPublishTime, latest

Constructor Detail

MessageIdStartCursor

public MessageIdStartCursor(org.apache.pulsar.client.api.MessageId messageId,
                            boolean inclusive)

The default inclusive behavior should be controlled in ConsumerBuilder.startMessageIdInclusive(). But pulsar has a bug and don't support this currently. We have to use entry + 1 policy 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.

Parameters:

messageId - The message id for start position.

inclusive - Whether we include the start message id in consuming result. This works only if we provide a specified message id instead of MessageId.earliest or MessageId.latest.

Method Detail

position

public CursorPosition position(String topic,
                               int partitionId)

Specified by:

position in interface StartCursor