Я создал приложение / задание Flink, используя концепции потребителей и производителей flink.
Теперь у меня есть еще одно требование, например, мне нужно создать приложение Producer, которое публикует данные в topic который потребляется выше Flink Application. Я создал это приложение Producer, используя KafkaProducer, и оно работает должным образом. Но мне также нужно запустить это приложение Producer как Flink Job. Я искал в Google, я не могу найти подробности для создания приложения Flink только с помощью Producer.