fix(kafka): 修改properties的方法调用

chaorongzhi · Oct 30, 2024 · a8da044 · a8da044
1 parent 18f3c7e
commit a8da044
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaConsumerThread.java b/...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));
                     }
                 });