重置JDBC Kafka Connector以便从时间开始开始拉行吗？

Kafka连接器可以利用主键和时间戳来确定需要处理的行。

我正在寻找一种重置连接器的方法，以便从时间开始进行处理。

因为要求是在分布式模式下运行，所以最简单的方法是将连接器名称更新为新值。这将提示您在connect-offsets主题中输入一个新条目，因为它看起来像是一个全新的连接器。然后，连接器应重新开始读取，就好像尚未将任何内容写入Kafka。您还可以手动将逻辑删除消息发送到与该特定连接器相关联的connect-offsets主题中的键，但是重命名比处理它要容易得多。此方法适用于所有源连接器，不仅适用于此处描述的JDBC连接器。