Jeremy Mei created FLINK-20778: ---------------------------------- Summary: the comment for kafka split offset type is wrong Key: FLINK-20778 URL: https://issues.apache.org/jira/browse/FLINK-20778 Project: Flink Issue Type: Improvement Components: Connectors / Kafka Reporter: Jeremy Mei Attachments: Screen Capture_select-area_20201228011944.png
the current code: {code:java} // Indicating the split should consume from the earliest. public static final long LATEST_OFFSET = -1; // Indicating the split should consume from the latest. public static final long EARLIEST_OFFSET = -2; {code} should be adjusted as blew {code:java} // Indicating the split should consume from the latest. public static final long LATEST_OFFSET = -1; // Indicating the split should consume from the earliest. public static final long EARLIEST_OFFSET = -2; {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)