Re: Can't start FlinkKafkaProducer using SSL

2021-08-24 Thread Fabian Paul
Hi Wouter, Can you share the jars which are part of the classpath? I can imagine that something was not bundled correctly. Best, Fabian

Can't start FlinkKafkaProducer using SSL

2021-08-23 Thread Wouter Zorgdrager
Hi all, I'm trying to deploy a FlinkKafkaProducer in PyFlink on a remote cluster. Unfortunately, I'm getting the following exception: Caused by: org.apache.flink.kafka.shaded.org.apache.kafka.common. KafkaException: Failed to construct kafka producer at org.apache.flink.kafka.shaded.org.apach