apache-kafka - 如何更新正在运行的 kafka 连接器

Question

我在 Marathon 容器中运行了 kafka conenct。如果我想更新连接器插件（jar），我必须上传新的，然后重新启动 Connect 任务。

是否可以在不重新启动/停机的情况下做到这一点？

Answer 1

需要将连接器插件的更新 jar 添加到类路径中，然后工作人员的类加载器需要将其拾取。目前执行此操作的最佳方法是按照此处所述进行中断。

根据您的连接器，您可能能够进行滚动升级，但一般的答案是，如果您需要升级连接器插件，您目前必须中断。