[ https://issues.apache.org/jira/browse/FLINK-31599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17704803#comment-17704803 ]
Tzu-Li (Gordon) Tai commented on FLINK-31599: --------------------------------------------- Merged to `apache/flink-connector-kafka:main` via 06789ec7b86a3b2edae1dc7f9f29d672ebd3610b > 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 > > 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)