Processing Kafka Sources and Sinks with Apache Flink in Python

This is a code walk through of the blog post https://thecodinginterface.com/blog/kafka-source-sink-with-apache-flink-table-api/ which discusses how to use Python and Apache Flink to consume data from Apache Kafka, perform computations on that source data then emit the computed results back out to Kafka.