我的生产者(SQL Server)已启动,Kafka已关闭.如何重新处理消息到卡夫卡?



我正在使用Debezium SQL Server Source连接器使用CDC将数据推送到Kafka。SQL Server 中表中的数据是连续插入。当 Kafka 关闭时,数据是否仍会插入到该表中?如果是这样,当我的卡夫卡启动时如何获得这些记录?

如果 Kafka 或 Kafka Connect 出现故障,当它重新启动时,它将从故障之前到达的点开始处理源数据。

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

最新更新