Hi Avi, have you tried to setup FlinkKafkaConsumer/FlinkKafkaProducer source/sink [1] with Kafka TLS config properties [2]?
Best, Andrey [1] https://ci.apache.org/projects/flink/flink-docs-master/dev/connectors/kafka.html <https://ci.apache.org/projects/flink/flink-docs-master/dev/connectors/kafka.html> [2] https://kafka.apache.org/documentation/#security_configclients > On 23 Dec 2018, at 13:02, Avi Levi <avi.l...@bluevoyant.com> wrote: > > Hi, > Can anyone give me an example for how to use kafka client with tls support ? > I must use tls to connect to our kafka > > Thanks in advance > Avi
