This is an automated email from the ASF dual-hosted git repository.
shenghang pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new 44454dcd3f [Improvement][Connector] Upgrade Kafka client version from
3.2.0 to 3.4.0 (#9941)
44454dcd3f is described below
commit 44454dcd3f35d9be979ec4140677cee801b1ec9b
Author: corgy-w <[email protected]>
AuthorDate: Tue Oct 28 09:40:18 2025 +0800
[Improvement][Connector] Upgrade Kafka client version from 3.2.0 to 3.4.0
(#9941)
Co-authored-by: factory-droid[bot]
<138933559+factory-droid[bot]@users.noreply.github.com>
---
seatunnel-connectors-v2/connector-kafka/pom.xml | 2 +-
.../connectors/seatunnel/kafka/sink/KafkaInternalProducer.java | 6 +++---
seatunnel-formats/seatunnel-format-compatible-connect-json/pom.xml | 4 ++--
3 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/seatunnel-connectors-v2/connector-kafka/pom.xml
b/seatunnel-connectors-v2/connector-kafka/pom.xml
index 9ffff7dbc0..dceb19f7d2 100644
--- a/seatunnel-connectors-v2/connector-kafka/pom.xml
+++ b/seatunnel-connectors-v2/connector-kafka/pom.xml
@@ -30,7 +30,7 @@
<name>SeaTunnel : Connectors V2 : Kafka</name>
<properties>
- <kafka.client.version>3.2.0</kafka.client.version>
+ <kafka.client.version>3.4.0</kafka.client.version>
<debezium.version>1.9.8.Final</debezium.version>
</properties>
diff --git
a/seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/sink/KafkaInternalProducer.java
b/seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/sink/KafkaInternalProducer.java
index 33d2caeb93..949a40a770 100644
---
a/seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/sink/KafkaInternalProducer.java
+++
b/seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/sink/KafkaInternalProducer.java
@@ -124,15 +124,15 @@ public class KafkaInternalProducer<K, V> extends
KafkaProducer<K, V> {
Object transactionManager = getTransactionManager();
synchronized (transactionManager) {
- Object topicPartitionBookkeeper =
+ Object txnPartitionMap =
ReflectionUtils.getField(
transactionManager,
transactionManager.getClass(),
- "topicPartitionBookkeeper")
+ "txnPartitionMap")
.get();
transitionTransactionManagerStateTo(transactionManager,
"INITIALIZING");
- ReflectionUtils.invoke(topicPartitionBookkeeper, "reset");
+ ReflectionUtils.invoke(txnPartitionMap, "reset");
ReflectionUtils.setField(
transactionManager,
diff --git a/seatunnel-formats/seatunnel-format-compatible-connect-json/pom.xml
b/seatunnel-formats/seatunnel-format-compatible-connect-json/pom.xml
index 9b4ea874cf..3b30715ddd 100644
--- a/seatunnel-formats/seatunnel-format-compatible-connect-json/pom.xml
+++ b/seatunnel-formats/seatunnel-format-compatible-connect-json/pom.xml
@@ -46,14 +46,14 @@
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
- <version>3.2.0</version>
+ <version>3.4.0</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>connect-json</artifactId>
- <version>3.2.0</version>
+ <version>3.4.0</version>
<scope>provided</scope>
</dependency>
