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

…tication
NicoK · Sep 24, 2021 · 5209f85 · 5209f85
1 parent 7bcd1d8
commit 5209f85
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 9 deletions.
diff --git a/import/src/main/java/com/ververica/platform/FlinkCommitsToKafka.java b/import/src/main/java/com/ververica/platform/FlinkCommitsToKafka.java
@@ -64,13 +64,13 @@ public static void main(String[] args) {
             + kafkaServer
             + "',\n"
             + (kafkaSecurityProtocol != null
-                ? "'properties.security.protocol' = '" + kafkaSecurityProtocol + "'"
+                ? "'properties.security.protocol' = '" + kafkaSecurityProtocol + "',\n"
                 : "")
             + (kafkaSaslMechanism != null
-                ? "''properties.sasl.mechanism' = '" + kafkaSaslMechanism + "'"
+                ? "''properties.sasl.mechanism' = '" + kafkaSaslMechanism + "',\n"
                 : "")
             + (kafkaSaslJaasConfig != null
-                ? "''properties.sasl.jaas.config' = '" + kafkaSaslJaasConfig + "'"
+                ? "''properties.sasl.jaas.config' = '" + kafkaSaslJaasConfig + "',\n"
                 : "")
             + "'properties.max.request.size' = '"
             + 5 * 1024 * 1024

diff --git a/import/src/main/java/com/ververica/platform/FlinkMailingListToKafka.java b/import/src/main/java/com/ververica/platform/FlinkMailingListToKafka.java
@@ -93,13 +93,13 @@ public static void main(String[] args) {
             + kafkaServer
             + "',\n"
             + (kafkaSecurityProtocol != null
-                ? "'properties.security.protocol' = '" + kafkaSecurityProtocol + "'"
+                ? "'properties.security.protocol' = '" + kafkaSecurityProtocol + "',\n"
                 : "")
             + (kafkaSaslMechanism != null
-                ? "''properties.sasl.mechanism' = '" + kafkaSaslMechanism + "'"
+                ? "''properties.sasl.mechanism' = '" + kafkaSaslMechanism + "',\n"
                 : "")
             + (kafkaSaslJaasConfig != null
-                ? "''properties.sasl.jaas.config' = '" + kafkaSaslJaasConfig + "'"
+                ? "''properties.sasl.jaas.config' = '" + kafkaSaslJaasConfig + "',\n"
                 : "")
             + "'properties.max.request.size' = '"
             + 20 * 1024 * 1024

diff --git a/import/src/main/java/com/ververica/platform/FlinkPullRequestsToKafka.java b/import/src/main/java/com/ververica/platform/FlinkPullRequestsToKafka.java
@@ -69,13 +69,13 @@ public static void main(String[] args) {
             + kafkaServer
             + "',\n"
             + (kafkaSecurityProtocol != null
-                ? "'properties.security.protocol' = '" + kafkaSecurityProtocol + "'"
+                ? "'properties.security.protocol' = '" + kafkaSecurityProtocol + "',\n"
                 : "")
             + (kafkaSaslMechanism != null
-                ? "''properties.sasl.mechanism' = '" + kafkaSaslMechanism + "'"
+                ? "''properties.sasl.mechanism' = '" + kafkaSaslMechanism + "',\n"
                 : "")
             + (kafkaSaslJaasConfig != null
-                ? "''properties.sasl.jaas.config' = '" + kafkaSaslJaasConfig + "'"
+                ? "''properties.sasl.jaas.config' = '" + kafkaSaslJaasConfig + "',\n"
                 : "")
             + "'format' = 'json'\n"
             + ")");