Docker, Java 17 SDK, Maven, Python 3, Kafka-Python:
pip install kafka-python
Start Kafka, Flink and Kafdrop with docker compose:
docker compose up
Wait few seconds for Kafka to start and start producer in another terminal:
python3 producer/producer.py
Build Flink executable and deploy it on Flink cluster:
sh ./build_and_deploy_flink.sh
Enter localhost:9000
in a web browser. You will see Kafdrop interface where you can monitor Kafka messages.