我的目标是使用debezium-connectors.和apache-kafka将数据更改流到新的数据库表中。但我一点也不知道怎么做到这一点。虽然我知道如何开始卡夫卡动物园管理员,创造主题,并订阅该主题。我不熟悉.How实现数据流并使用Change data Capture(CDC)将数据捕获到新数据库表的所有后续步骤。
发布于 2022-06-04 14:16:23
Debezium只向Kafka提供数据。不会读卡夫卡或写到一个新的数据库。
您可以使用JDBC Sink Kafka连接器查看他们的一篇旧博客文章,以写入新服务器。
https://debezium.io/blog/2017/09/25/streaming-to-another-database/
https://stackoverflow.com/questions/72498164
复制相似问题