You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Owen Lee (Jira)" <ji...@apache.org> on 2022/11/10 09:42:00 UTC
[jira] [Updated] (FLINK-29978) FlinkKafkaInternalProducer not compatible with kafka-client-3.3.x
[ https://issues.apache.org/jira/browse/FLINK-29978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Owen Lee updated FLINK-29978:
-----------------------------
Description:
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 the field name should be corrected accordingly.
was:
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.
> 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
> Priority: Major
>
> 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 the field name should be corrected accordingly.
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)