我的 Producer（SQL 服务器）已启动，而 Kafka 已关闭。如何重新处理消息到kafka？

Question

我正在使用 Debezium SQL 服务器源连接器使用 CDC 将数据推送到 Kafka。 table in SQL 服务器中的数据是连续插入的。当 Kafka 宕机时，数据还会被插入到 table 中吗？如果是这样，当我的 Kafka 启动时如何获取这些记录？

Answer 1

如果 Kafka 或 Kafka Connect 出现故障，当它重新启动时，它将从故障前的位置开始处理源数据。

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