Apache Beam has a built-in connector for Debezium called DebeziumIO. It lets you capture changes from your database and process them directly inside a Beam pipeline. You don’t need to run Apache Kafka or Kafka Connect.
In this post, we’ll build an example pipeline tha...