(flink-connector-kafka) 02/02: [hotfix] Fix misleading log message in setTransactionId

[fanrui]

This is an automated email from the ASF dual-hosted git repository.

fanrui pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-kafka.git

commit 95e38963a327ec522cc0cd28c083fb08f93638bd
Author: Aleksandr Savonin <savoni...@gmail.com>
AuthorDate: Mon Nov 10 18:56:31 2025 +0100

    [hotfix] Fix misleading log message in setTransactionId
---
 .../flink/connector/kafka/sink/internal/FlinkKafkaInternalProducer.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/FlinkKafkaInternalProducer.java
 
b/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/FlinkKafkaInternalProducer.java
index 2934a194..053bf94b 100644
--- 
a/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/FlinkKafkaInternalProducer.java
+++ 
b/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/FlinkKafkaInternalProducer.java
@@ -179,7 +179,7 @@ public class FlinkKafkaInternalProducer<K, V> extends 
KafkaProducer<K, V> {
     public void setTransactionId(String transactionalId) {
         checkState(
                 !isInTransaction(),
-                String.format("Another transaction %s is still open.", 
transactionalId));
+                String.format("Another transaction %s is still open.", 
this.transactionalId));
         LOG.debug("Change transaction id from {} to {}", this.transactionalId, 
transactionalId);
         this.transactionalId = transactionalId;
         Object transactionManager = getTransactionManager();