According to the definition, Apache Beam is an open source unified programming model to define and execute data processing pipelines, including ETL, batch, and stream processing. This recipe shows how to read Kafka with Apache Beam.
Reading Kafka with Apache Beam
Getting ready
To install Apache Beam, follow the instructions at:Â https://beam.apache.org/get-started/quickstart-py/.
How to do it...
The following code shows how to write a Beam pipeline to read from Kafka. The example illustrates various options for configuring the Beam source:
pipeline .apply...