diff --git a/seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaConsumerThread.java b/seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaConsumerThread.java
index b789a67adcb..f0dd6aab91e 100644
--- a/seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaConsumerThread.java
+++ b/seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaConsumerThread.java
@@ -88,7 +88,7 @@ private KafkaConsumer<byte[], byte[]> initConsumer(
                     if ("java.security.krb5.conf".equals(key)) {
                         System.setProperty("java.security.krb5.conf", String.valueOf(value));
                     } else {
-                        props.put(key, value);
+                        props.setProperty(String.valueOf(key), String.valueOf(value));
                     }
                 });