[
https://issues.apache.org/jira/browse/FLINK-29977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-29977.
------------------------------------
Resolution: Duplicate
> Kafka connector not compatible with kafka-clients 3.3x
> ------------------------------------------------------
>
> Key: FLINK-29977
> URL: https://issues.apache.org/jira/browse/FLINK-29977
> Project: Flink
> Issue Type: Technical Debt
> Components: Connectors / Kafka
> Affects Versions: 1.16.0
> Reporter: Chesnay Schepler
> Assignee: Chesnay Schepler
> Priority: Major
> Labels: pull-request-available
>
> In
> https://github.com/apache/kafka/commit/3ea7b418fb3d7e9fc74c27751c1b02b04877f197
> the TransactionManager was modified and no longer has a
> {{topicPartitionBookkeeper}} that we access via reflection.
> The {{TopicPartitionBookkeeper}} was refactored to a {{TxnPartitionMap}}
> class.
> The {{reset}} method we require is still present though; so this could
> potentially be fixed by just falling back to another field name if required.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
