如何捕获 YugabyteDB 对 kafka 的更改?

How to capture YugabyteDB changes to kafka?

[用户在 YugabyteDB Community Slack 上发布的问题]

如果我想捕获所有数据库更新并将它们发送到 Kafka 主题,您是否有建议的解决方案?

您可以使用 Yugabyte Source Connector for Kafka for both YCQL & YSQL apis. This is based on JDBC Source connector 来获取数据 select *

Yugabyte 团队最近发布了一个用于 YugabyteDB 的 Debezium 连接器 https://github.com/yugabyte/debezium/releases

文档位于https://docs.yugabyte.com/preview/explore/change-data-capture/debezium-connector-yugabytedb/