First I'd check whether kafkaRequiresSsl is actually true when the job
is submitted.
(actually just remove the condition and see what happens)
Would this supposed SSL OOM happen only if the client uses SSL?
On 03/02/2022 03:40, Marco Villalobos wrote:
According to the Flink 1.12 documentation
According to the Flink 1.12 documentation (
https://nightlies.apache.org/flink/flink-docs-release-1.12/dev/connectors/kafka.html),
it states to use FlinkKafkaSource when consuming from Kafka.
However, I noticed that the newer API uses KafkaSource, which uses
KafkaSourceBuilder and OffsetsInitializ
