我知道如何删除 Kafka 连接器,如此处所述Kafka Connect - 如何删除连接器 https://stackoverflow.com/questions/48947250/kafka-connect-how-to-delete-a-connector
但我不确定它是否还会从该工作人员的 *.sorage.topic 中删除/删除与特定连接器相关的配置、偏移量和状态?
For e.g:假设我删除了一个连接器名称为“connector-abc-1.0.0”的连接器,并且 Kafka 连接工作线程是使用以下配置启动的。
offset.storage.topic=<topic.name>.internal.offsets
config.storage.topic=<topic.name>.internal.configs
status.storage.topic=<topic.name>.internal.status
- 现在,在对该连接器进行 DELETE 调用之后,它是否会删除该特定连接器的上述内部主题中的所有记录?
- 这样我就可以在同一工作人员上创建具有“相同名称”但配置不同(不同的 offset.start 或connector.class)的新连接器?
删除连接器时,偏移量将保留在偏移主题中。
如果您重新创建具有相同名称的连接器,它将重新使用上次执行的偏移量(即使连接器在中间被删除)。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)