[FLINK-32021] Improvement the Javadoc for SpecifiedOffsetsInitializer and TimestampOffsetsInitializer.

• Type: Sub-task
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: kafka-3.0.0
• Fix Version/s: kafka-3.1.0
• Component/s: Connectors / Kafka
• Labels: pull-request-available
• Assignee: Hongshun Wang
• Reporter: Hongshun Wang
• Created: 06/May/23 03:18
• Updated: 26/Jan/24 08:33
• Resolved: 11/Jul/23 02:25

Description

As described in FLIP-288, Current JavaDoc does not fully explain the behavior of OffsetsInitializers. When the partition does not meet the condition, there will be a different offset strategy. This may lead to misunderstandings in the design and usage.

 

Add to SpecifiedOffsetsInitializer: "Use Specified offset for specified partitions while use commit offset or Earliest for unspecified partitions. Specified partition offset should be less than the latest offset, otherwise it will start from the earliest."

 

Add to TimestampOffsetsInitializer:Initialize the offsets based on a timestamp. If the message meeting the requirement of the timestamp have not been produced to Kafka yet, just use the latest offset.

Issue Links

• links to: GitHub Pull Request #29