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. Hope this helps! Cheers, Gordon [1] https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/connectors/kafka.html -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
