From 3504ef21a4e04f6030e430be5bfa8b9db4054791 Mon Sep 17 00:00:00 2001 From: Nico Kruber Date: Fri, 24 Sep 2021 14:03:42 +0200 Subject: [PATCH] fixup! [import] allow configuring Kafka tables for use of SASL authentication --- .../platform/FlinkMailingListToKafka.java | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) diff --git a/import/src/main/java/com/ververica/platform/FlinkMailingListToKafka.java b/import/src/main/java/com/ververica/platform/FlinkMailingListToKafka.java index d052661..39aaae0 100644 --- 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 + "',"