AHeise commented on code in PR #195:
URL:
https://github.com/apache/flink-connector-kafka/pull/195#discussion_r2527536824
##########
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/split/KafkaPartitionSplit.java:
##########
@@ -41,14 +41,20 @@ public class KafkaPartitionSplit implements SourceSplit {
public static final long EARLIEST_OFFSET = -2;
// Indicating the split should consume from the last committed offset.
public static final long COMMITTED_OFFSET = -3;
- // Used to indicate the split has been migrated from an earlier enumerator
state; offset needs
- // to be initialized on recovery
+ // Used to indicate the offset has not been initialized yet in the
enumerator state; offset
+ // needs to be initialized on recovery
public static final long MIGRATED = Long.MIN_VALUE;
+ public static final long MIGRATED_INITIAL = MIGRATED + 1;
Review Comment:
I revised and was able to reduce the cases, such that we just need to have
one MIGRATED.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
