我的目标是使用apache-kafka*和debezium-connectors将数据更改流到新的数据库表中。但是我对如何实现它没有丝毫的想法。虽然我知道如何启动kafka-zookeeper,创建主题,并订阅该主题。我不熟悉所有后续步骤。如何实现数据流*并使用将数据捕获到新的数据库表中变更数据捕获(CDC)?
bfhwhh0e1#
Debezium只会将数据输入Kafka,不会读取Kafka的数据,也不会写入新的数据库。您可以使用JDBCSinkKafkaConnector将他们的旧blog文章写入新服务器https://debezium.io/blog/2017/09/25/streaming-to-another-database/
1条答案
按热度按时间bfhwhh0e1#
Debezium只会将数据输入Kafka,不会读取Kafka的数据,也不会写入新的数据库。
您可以使用JDBCSinkKafkaConnector将他们的旧blog文章写入新服务器
https://debezium.io/blog/2017/09/25/streaming-to-another-database/