Alex Sorokoumov created FLINK-31599:
---------------------------------------

             Summary: Update Kafka dependency in flink-connector-kafka to 3.4.0
                 Key: FLINK-31599
                 URL: https://issues.apache.org/jira/browse/FLINK-31599
             Project: Flink
          Issue Type: New Feature
          Components: Connectors / Kafka
            Reporter: Alex Sorokoumov


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
* 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to