问我的生产者(SQL Server)打开了，Kafka关闭了。如何重新处理发往kafka的消息？
EN

Stack Overflow用户

提问于 2020-05-22 15:39:43

回答 1查看 29关注 0票数 0

我正在使用Debezium SQL Server Source connector通过CDC将数据推送到Kafka。SQL Server表中的数据是连续插入的。当Kafka宕机时，数据还会插入到该表中吗？如果是这样，当我的Kafka打开时，如何获得这些记录？

回答已采纳

发布于 2020-05-22 18:37:43

如果Kafka或Kafka Connect关闭，当它重新启动时，它将从故障前的点开始处理源数据。

分布式模式下的Kafka Connect使用Kafka本身来跟踪从源系统读取的记录的详细信息。

票数 0

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/61950010

复制

相似问题

问我的生产者(SQL Server)打开了，Kafka关闭了。如何重新处理发往kafka的消息？EN