Owen Lee created FLINK-29978:
--------------------------------
Summary: FlinkKafkaInternalProducer not compatible with
kafka-client-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
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}
Users should be advised not to use version 3.3.x or variable name should be
corrected.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
