我正在使用 Apache Kafka 并使用分布式工作器。我可以按如下方式启动我的工人：
// Command to start the distributed worker.
"bin/connect-distributed.sh config/connect-distributed.properties"
这是来自官方文档。在此之后，我们可以创建连接器和任务。这很好用。
但是当我更改我的连接器或任务逻辑时，我应该将新的添加jar到 kafka 的类路径中。在此之后我应该重新启动工人。
我不知道应该如何正确我认为我们应该停止并运行工人。
但是当我想停止工人时，我不知道如何正确地做到这一点。当然，我可以找到我的进程ps aux | grep worker，杀死它并杀死我也应该找到的其余服务器ps。但我认为这是一个奇怪的案例。杀死两个进程不是一个好主意，但我找不到任何信息我们可以如何以另一种方式做到这一点。
如果你知道正确的方法，请帮助我:)
谢谢你的时间。