[jira] [Updated] (FLINK-31599) Update Kafka dependency in flink-connector-kafka to 3.4.0

["Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-31599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Tzu-Li (Gordon) Tai updated FLINK-31599:
----------------------------------------
    Fix Version/s: kafka-3.1.0
                       (was: kafka-5.0.0)

> 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: Technical Debt
>          Components: Connectors / Kafka
>            Reporter: Alex Sorokoumov
>            Assignee: Alex Sorokoumov
>            Priority: Minor
>              Labels: pull-request-available
>             Fix For: kafka-3.1.0
>
>
> 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)