apache-kafka - 如何杀死 Kafka 集群中的分布式 worker ？

Question

我正在使用 Apache Kafka 并使用分布式 worker 。我可以开始我的 worker 如下:

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

这是来自官方文档。在此之后，我们可以创建连接器和任务。这工作正常。

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

我不知道应该怎么做我认为我们应该停止并运行 worker 。

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

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

谢谢你的时间。

Answer 1

Killing two processes isn't good idea

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

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

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