【发布时间】:2019-02-12 17:12:32
【问题描述】:
我有一个带有多个连接器(例如 C1 和 C2)的 Kafka Connect 集群,我有一个工作人员运行 2 个任务,一个带有连接器 C1,一个带有连接器 C2。 我已经更新了连接器 C1 的代码并替换了插件目录中的 jar,是否足以重新启动运行 C1 的任务,或者我需要重新启动工作程序(并且它运行的所有任务都将重新启动)?
谢谢
【问题讨论】:
我有一个带有多个连接器(例如 C1 和 C2)的 Kafka Connect 集群,我有一个工作人员运行 2 个任务,一个带有连接器 C1,一个带有连接器 C2。 我已经更新了连接器 C1 的代码并替换了插件目录中的 jar,是否足以重新启动运行 C1 的任务,或者我需要重新启动工作程序(并且它运行的所有任务都将重新启动)?
谢谢
【问题讨论】:
如果您希望 Kafka Connect 获取已更改的 JAR,则需要重新启动工作程序本身。 Task 只是 Worker 本身内的一个逻辑执行单元。
更多信息:
【讨论】: