[jira] [Commented] (FLINK-29978) FlinkKafkaInternalProducer not compatible with kafka-clients-3.3.x

["Weijie Guo (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/FLINK-29978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17631562#comment-17631562 ] 

Weijie Guo commented on FLINK-29978:
------------------------------------

Is this the same problem with FLINK-29977?

> FlinkKafkaInternalProducer not compatible with kafka-clients-3.3.x
> ------------------------------------------------------------------
>
>                 Key: FLINK-29978
>                 URL: https://issues.apache.org/jira/browse/FLINK-29978
>             Project: Flink
>          Issue Type: Bug
>          Components: Connectors / Kafka
>    Affects Versions: 1.16.0
>            Reporter: Owen Lee
>            Priority: Minor
>
> FlinkKafkaInternalProducer _resumeTransaction_ fetches _topicPartitionBookkeeper_ field from _TransactionManager_ which has been renamed to _TxnPartitionMap_ in 3.3.x. Failing to retrieve the field raises an exception (Incompatible KafkaProducer version)
>  
> {code:java}
> public void resumeTransaction(long producerId, short epoch) {
>   ...
>   Object topicPartitionBookkeeper = getField(transactionManager, "topicPartitionBookkeeper");
> ...
> }
> {code}
>  
> [https://github.com/apache/kafka/blob/3.3.0/clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java]
> {code:java}
> private final TxnPartitionMap txnPartitionMap; {code}
> Users should be advised not to use version 3.3.x or the field name should be corrected accordingly.
>  



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