Reproduced from https://thecodinginterface.com/blog/kafka-source-sink-with-apache-flink-table-api/
PyFlink is compatible with Python>=3.5<3.9
Process:
- Produce events and send to Kafka topic
- Set up streaming service via PyFlink DataStream API
- Read from Kafka source via PyFlink TABLE API
- Process data