Kafka connect -完全删除一个连接器



我的问题分为两个。我读过Kafka Connect - Delete Connector with configs?我希望完全删除连接器,包括偏移量和所有内容,以便以后可以使用相同的名称重新创建它。这可能吗?根据我的理解,墓碑消息将无限期地终止此连接器。

第二部分是-是否有一种方法可以让kafka-connect容器在将其关闭时自动删除他创建的所有连接器?由于

没有完全清除连接器状态的命令。对于汇聚连接器,您可以使用kafka-consumer-groups重置其偏移量。对于源连接器,这并不那么简单,因为您需要手动将数据生成到Connect-managed偏移量主题中。

配置和状态主题也保存历史数据,但不应阻止您重新创建具有相同名称/详细信息的连接器。

Confluent和Debezium发布的Connect容器总是使用分布式模式。你需要覆盖容器的入口点,使用独立模式来不将连接器元数据持久化到Kafka主题中(这不会容错,但对于测试来说是可以的)

相关内容

  • 没有找到相关文章

最新更新