流数据库(mariadb)使用apache-kafka和debezium连接器更改为另一个数据库表

o3imoua4  于 2022-11-08  发布在  Apache
关注(0)|答案(1)|浏览(101)

我的目标是使用apache-kafka*debezium-connectors将数据更改流到新的数据库表中。但是我对如何实现它没有丝毫的想法。虽然我知道如何启动kafka-zookeeper,创建主题,并订阅该主题。我不熟悉所有后续步骤。如何实现数据流*并使用将数据捕获到新的数据库表中变更数据捕获(CDC)

bfhwhh0e

bfhwhh0e1#

Debezium只会将数据输入Kafka,不会读取Kafka的数据,也不会写入新的数据库。
您可以使用JDBCSinkKafkaConnector将他们的旧blog文章写入新服务器
https://debezium.io/blog/2017/09/25/streaming-to-another-database/

相关问题