Search code examples
apache-kafkacdcyugabytedb

How to capture YugabyteDB changes to kafka?


[Question posted by a user on YugabyteDB Community Slack]

If I want to capture all the DB updates and send them to a Kafka topic, is there a solution you may suggest?


Solution

  • You can use Yugabyte Source Connector for Kafka for both YCQL & YSQL apis. This is based on JDBC Source connector that does select * to get the data.