Apache-beam-with-flink This is for POC to use Apache beam with Flink Runner and Python SDK ** Make Sure kafka cluster is up and running docker build -t custom-flink . kubectl apply -f flink-configmap.yaml kubectl apply -f flink.yaml