Is there any real example of creating a datastream for Kafa Connector in Java? There are many examples online using FlinkKafkaProducer09, FlinkKafkaProducer11… but the latest version of flink api does not contain does classes and FlinkKafkaProducer class is deprecated!

Something like https://docs.immerok.cloud/docs/how-to-guides/development/exactly-once-with-apache-kafka-and-apache-flink/ ?

Thanks @Martijn Visser It worked!