convert Scala code to Python (Dataflow pipeline)

Need to convert existing simple Scala code to Python (Dataflow pipeline - Apache Beam) . It has 2 components: Batch Processing Pipeline and Streaming processing. You should have knowledge of Python, Kafka, Google Cloud Platform and Apache Beam. Once completed I need a quick session on what and how you carried out the conversion and how to deploy the same.


Dataflow Pipelines (Batch and Streaming)
Deployment Steps