How To Consume Messages Using Beam's External Kafka Transform (locally)

I am trying to run an app that uses a kafka producer (Python client), and an apache beam pipeline that will (for now) simply consume those messages by printing them to STDOUT. I un

Solution 1:

I think the universal runner is located under apache_beam.runners.portability.portable_runner.