Hi Alex, Kafka authentication and data transfer encryption using SSL can be simply done be configuring brokers and the connecting client.
You can take a look at this: https://kafka.apache.org/documentation/#security_ssl. The Kafka client that the Flink connector uses can be configured through the `Properties` configuration provided when instantiating `FlinkKafkaConsumer`. You just need to set values for these config properties: https://kafka.apache.org/documentation/#security_configclients. Note that SSL truststore / keystore locations must exist on all of your Flink TMs for this to work. Hope this helps! - Gordon -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/kafka-ssl-how-to-enable-ssl-authentication-for-a-new-kafka-consumer-tp11532p11610.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
