From 246174afb2c6850df737214c3f633f5934d3c62d Mon Sep 17 00:00:00 2001 From: Enrico Olivelli Date: Wed, 14 Jul 2021 10:50:04 +0200 Subject: [PATCH] Debezium: Make pulsar.auth.token optional (and make Integration Tests pass) --- .../apache/pulsar/io/kafka/connect/PulsarKafkaWorkerConfig.java | 1 + 1 file changed, 1 insertion(+) diff --git a/pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/PulsarKafkaWorkerConfig.java b/pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/PulsarKafkaWorkerConfig.java index 920927413ba4c..7044b48d3fbe2 100644 --- a/pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/PulsarKafkaWorkerConfig.java +++ b/pulsar-io/kafka-connect-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,