我的问题分为两个。我读过Kafka Connect - Delete Connector with configs?。我想 * 完全 * 删除一个连接器，包括偏移量和所有内容，这样我就可以在以后用相同的名称重新创建它。这可能吗？据我所知，tombstone消息将无限期地终止这个连接器。
第二部分是--有没有办法让kafka-connect容器在关闭时自动删除他创建的所有连接器？
我的问题分为两个。我读过Kafka Connect - Delete Connector with configs?。我想 * 完全 * 删除一个连接器，包括偏移量和所有内容，这样我就可以在以后用相同的名称重新创建它。这可能吗？据我所知，tombstone消息将无限期地终止这个连接器。
第二部分是--有没有办法让kafka-connect容器在关闭时自动删除他创建的所有连接器？
1条答案
按热度按时间yh2wf1be1#
没有这样的命令可以完全清除连接器状态。对于接收连接器，可以使用
kafka-consumer-groups重置其偏移量。对于源连接器，这并不简单，因为您需要手动生成数据到连接管理的偏移量主题中。配置和状态主题也保留历史数据，但不应阻止您重新创建具有相同名称/详细信息的连接器。
Confluent和Debezium发布的Connect容器始终使用分布式模式。您需要覆盖容器的入口点以使用独立模式，从而不在Kafka主题中持久保存连接器元数据（这将不具备容错能力，但对于测试来说是可以的）