如何杀死 Kafka 集群中的分布式工作人员？答案

【问题标题】：How can i kill distributed worker in Kafka cluster?如何杀死 Kafka 集群中的分布式工作人员？
【发布时间】：2017-03-08 15:11:19
【问题描述】：

我正在使用 Apache Kafka 并使用分布式工作器。我可以按如下方式启动我的工人：

// Command to start the distributed worker.
"bin/connect-distributed.sh config/connect-distributed.properties"

这是来自官方文档。在此之后，我们可以创建连接器和任务。这很好用。

但是当我更改连接器或任务逻辑时，我应该将新的jar 添加到 kafka 的类路径中。在此之后我应该重新启动工人。

我不知道应该如何正确我认为我们应该停止并运行工人。

但是当我想停止工人时，我不知道如何正确地做到这一点。当然，我可以通过ps aux | grep worker 找到我的进程，杀死它并杀死我应该通过ps 找到的其余服务器。但我认为这是一个奇怪的案例。杀死两个进程不是一个好主意，但我找不到任何信息我们可以如何以另一种方式做到这一点。

如果你知道正确的方法，请帮助我:)

感谢您的宝贵时间。

【问题讨论】：

有一个 shell 脚本可以在融合的较新版本中停止其余服务器。请检查“kafka-rest-stop.sh”以停止休息服务器。但是没有脚本可用于停止工人。甚至我也通过终止进程来停止。

【解决方案1】：

杀死两个进程不是个好主意

ConnectDistributed 只是一个进程。没有单独的 REST 服务器可以停止。

是的，:connector/pause 后跟 kill <pid> 是阻止它的正确方法。

如果安装了最新版本的 Confluent Platform，您可以使用 systemctl 停止/启动。

【讨论】：