Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4928#discussion_r148204398 --- Diff: flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionState.java --- @@ -95,6 +95,10 @@ public final boolean isOffsetDefined() { return offset != KafkaTopicPartitionStateSentinel.OFFSET_NOT_SET; } + public final boolean isSentinel() { --- End diff -- nit: would `hasSentinelOffset` be a better name here?
---