public static class KafkaCheckpointMark.PartitionMark
extends java.lang.Object
implements java.io.Serializable
Constructor and Description |
---|
PartitionMark(java.lang.String topic,
int partition,
long offset,
long watermarkMillis) |
Modifier and Type | Method and Description |
---|---|
long |
getNextOffset() |
int |
getPartition() |
java.lang.String |
getTopic() |
long |
getWatermarkMillis() |
java.lang.String |
toString() |