/Apache-beam-with-flink

This is for POC of use Apache beam with Flink Runner and Python SDK

Primary LanguageDockerfile

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