Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-25152 FLIP-188: Introduce Built-in Dynamic Table Storage
  3. FLINK-25184

Introduce setDeliveryCallback to KafkaWriter

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Closed
    • Major
    • Resolution: Duplicate
    • None
    • 1.15.0
    • Connectors / Kafka
    • None

    Description

      The method can be package level visibility.

      Inside the managed table, we rely on this callback to know the offset of the written message and use this offset to do full and incremental alignment.

      Attachments

        Issue Links

          is duplicated by

          Sub-task - The sub-task of the issue FLINK-25696 Introduce metadataConsumer to InitContext in Sink

          • Major - Major loss of function.
          • Closed

          Activity

            People

              Unassigned Unassigned
              lzljs3620320 Jingsong Lee
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: