Re: Flink TLS in K8s

2020-11-06 Thread Patrick Eifler
11/5/2020 4:23 PM, Patrick Eifler wrote: > > Hi, > > I did set up a flink session cluster on K8s. > > Now I added the ssl configuration as shown in the documentation: > > # Flink TLS > security.ssl.internal.enabled: true > security.ssl.internal.keystore: &

Flink TLS in K8s

2020-11-05 Thread Patrick Eifler
Hi, I did set up a flink session cluster on K8s. Now I added the ssl configuration as shown in the documentation: # Flink TLS security.ssl.internal.enabled: true security.ssl.internal.keystore: /config/internal-keystore/internal.keystore.jks security.ssl.internal.truststore: /config/internal-k

Run Flink Job with Confluent Schema Registry over SSL

2020-11-03 Thread Patrick Eifler
Hello, I'm running a Flink Session Cluster on K8s and deploy the Flink jobs using the the Flink rest API. The jobs using Avro for the producers and consumers. The jobs consume and produce from/to a secured Kafka cluster via TLS and SCRAM-SHA. Everything works as expected. Now I need to introdu