如何杀死kafka集群中的分布式工作者?

50few1ms  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(363)

我正在使用apachekafka和分布式worker。我可以启动我的工人如下:

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

这是官方文件。在此之后,我们可以创建连接器和任务。这个很好用。
但是当我更改连接器或任务逻辑时,我应该添加新的 jar Kafka的类路径。在这之后我应该重新开始工作。
我不知道该怎么做才对,我想我们应该停下来跑掉。
但当我想阻止工人时,我不知道如何才能正确地做到这一点。当然,我可以通过 ps aux | grep worker ,杀死它并杀死我应该找到的rest服务器 ps 我也是。但我觉得情况很奇怪。杀死两个进程不是一个好主意,但我找不到任何信息我们可以用另一种方法来做。
如果你知道正确的方法,请帮助我:)
谢谢你的时间。

hfyxw5xn

hfyxw5xn1#

杀死两个进程不是个好主意 ConnectDistributed 只是一个过程。没有单独的rest服务器可以停止。
是的, :connector/pause 接着是一个 kill <pid> 是阻止它的正确方法。
如果与最新版本的confluent platform一起安装,则可以停止/开始使用 systemctl .

相关问题