fixup! [import] allow configuring Kafka tables for use of SASL authen…

…tication
NicoK · Sep 24, 2021 · 3504ef2 · 3504ef2
1 parent 3ca1eea
commit 3504ef2
Showing 1 changed file with 18 additions and 0 deletions.
diff --git a/import/src/main/java/com/ververica/platform/FlinkMailingListToKafka.java b/import/src/main/java/com/ververica/platform/FlinkMailingListToKafka.java
@@ -123,6 +123,15 @@ public static void main(String[] args) {
             + "'properties.bootstrap.servers' = '"
             + kafkaServer
             + "',\n"
+            + (kafkaSecurityProtocol != null
+                ? "'properties.security.protocol' = '" + kafkaSecurityProtocol + "',\n"
+                : "")
+            + (kafkaSaslMechanism != null
+                ? "'properties.sasl.mechanism' = '" + kafkaSaslMechanism + "',\n"
+                : "")
+            + (kafkaSaslJaasConfig != null
+                ? "'properties.sasl.jaas.config' = '" + kafkaSaslJaasConfig + "',\n"
+                : "")
             + "'properties.max.request.size' = '"
             + 20 * 1024 * 1024
             + "',"
@@ -145,6 +154,15 @@ public static void main(String[] args) {
             + "'properties.bootstrap.servers' = '"
             + kafkaServer
             + "',\n"
+            + (kafkaSecurityProtocol != null
+                ? "'properties.security.protocol' = '" + kafkaSecurityProtocol + "',\n"
+                : "")
+            + (kafkaSaslMechanism != null
+                ? "'properties.sasl.mechanism' = '" + kafkaSaslMechanism + "',\n"
+                : "")
+            + (kafkaSaslJaasConfig != null
+                ? "'properties.sasl.jaas.config' = '" + kafkaSaslJaasConfig + "',\n"
+                : "")
             + "'properties.max.request.size' = '"
             + 20 * 1024 * 1024
             + "',"