Re: Run Flink Job with Confluent Schema Registry over SSL

2020-11-03 Thread Robert Metzger
Hi Patrick, The upcoming Flink 1.12 release will update the version to 5.4.2 at least: https://github.com/apache/flink/pull/12919/files This is closer to what you need, but still not there :( What you can try is compile your own version of flink-avro-confluent-registry, where you pass -Dconfluent

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