Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-31953 FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source
  3. FLINK-32021

Improvement the Javadoc for SpecifiedOffsetsInitializer and TimestampOffsetsInitializer.

    XMLWordPrintableJSON

Details

    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.

      Attachments

        Issue Links

          Activity

            People

              loserwang1024 Hongshun Wang
              loserwang1024 Hongshun Wang
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: