Debezium: Make pulsar.auth.token optional (and make Integration Tests…

… pass)
datastax · Jul 14, 2021 · 246174a · 246174a
1 parent 5445344
commit 246174a
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...ect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/PulsarKafkaWorkerConfig.java b/...ect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/PulsarKafkaWorkerConfig.java
@@ -68,6 +68,7 @@ public class PulsarKafkaWorkerConfig extends WorkerConfig {
                 PULSAR_SERVICE_URL_CONFIG_DOC)
             .define(PULSAR_AUTH_TOKEN_CONFIG,
                 Type.STRING,
+                "",
                 Importance.HIGH,
                 PULSAR_AUTH_TOKEN_CONFIG_DOC)
             .define(TOPIC_NAMESPACE_CONFIG,