Package | Description |
---|---|
org.apache.flink.connector.pulsar.source.enumerator.cursor | |
org.apache.flink.connector.pulsar.source.enumerator.cursor.start |
Modifier and Type | Method and Description |
---|---|
CursorPosition |
StartCursor.position(String topic,
int partitionId) |
Modifier and Type | Method and Description |
---|---|
CursorPosition |
TimestampStartCursor.position(String topic,
int partitionId) |
CursorPosition |
MessageIdStartCursor.position(String topic,
int partitionId) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.