如何更新正在运行的 kafka 连接器答案

【问题标题】：How to update running kafka connector如何更新正在运行的 kafka 连接器
【发布时间】：2017-03-25 19:24:27
【问题描述】：

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

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

【问题讨论】：

【解决方案1】：

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

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

【讨论】：

除此之外，绝大多数连接器都可以滚动升级。因此，在许多情况下，如果您让 Connect 在分布式模式下运行，则不需要停机。但是，正如@dawsaw 所说，这取决于以兼容方式编写的连接器（而不仅仅是向后兼容，因为在升级期间分配可能会在新旧版本的连接器之间切换）。