Re: Upgrading to the new KafkaSink + Flink 1.14 from Flink 1.13.2 + FlinkKafkaProducer

[Fabian Paul]

Hi Yuval,

Ok no worries. One thing I would first check is why the 
TwoPhaseCommitSinkFunction is instantiated because the KafkaSink is not using 
it. It 
seems there is still an old FlinkKafkaProducer build somewhere.

Best,
Fabian