Posted by Tzu-Li (Gordon) Tai on URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Flink-job-testing-with-tp19573p19604.html
Hi,
The docs here [1] provide some example snippets of using the Kafka connector
to consume from / write to Kafka topics.
Once you consumed a `DataStream` from a Kafka topic using the Kafka
consumer, you can use Flink transformations such as map, flatMap, etc. to
perform processing on the records.