Re: #kafka/#ssl: how to enable ssl authentication for a new kafka consumer?

Posted by Tzu-Li (Gordon) Tai on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/kafka-ssl-how-to-enable-ssl-authentication-for-a-new-kafka-consumer-tp11532p11610.html

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