Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-31599

Update Kafka dependency in flink-connector-kafka to 3.4.0

    XMLWordPrintableJSON

Details

    Description

      There is a number of reasons to upgrade to the latest version.
       
      First, the Kafka connector uses reflection, so internal changes in Kafka clients' implementation might require changes in the connector. With more frequent upgrades, the amount of work per upgrade is smaller.
       
      Second, there were a number of relevant bug fixes since 3.2.3:

      • KAFKA-14303 - Producer.send without record key and batch.size=0 goes into infinite loop
      • KAFKA-14379 - consumer should refresh preferred read replica on update metadata
      • KAFKA-14422 - Consumer rebalance stuck after new static member joins a group with members not supporting static members
      • KAFKA-14417 - Producer doesn't handle REQUEST_TIMED_OUT for InitProducerIdRequest, treats as fatal error
      • KAFKA-14532 - Correctly handle failed fetch when partitions unassigned

      Attachments

        Issue Links

          Activity

            People

              Gerrrr Alex Sorokoumov
              Gerrrr Alex Sorokoumov
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: