Setting up kafka flink connector project with example

Question

As i am new to kafka flink connector help me in suggesting some simple example program where kafka writes in a topic and flink listens it and display the values along with pom.xml.

Answer 1

The Flink operations playground does exactly that. This is a complete environment for learning about how to use Flink. The documentation describes what this application is doing, how to start and stop it, how to use the Flink Web UI, REST API, and CLI to control and observe what's happening, etc.

This docker-based example includes:

• a Kafka broker plus Zookeeper
• a simple click event generator that writes events to a Kafka input topic
• a Flink application that counts these events with time windows and writes the results to Kafka output topic
• a small Flink cluster to run the Flink job

The pom.xml file is here.