我正在使用apachekafka和分布式worker。我可以启动我的工人如下:
// Command to start the distributed worker.
"bin/connect-distributed.sh config/connect-distributed.properties"
这是官方文件。在此之后,我们可以创建连接器和任务。这个很好用。
但是当我更改连接器或任务逻辑时,我应该添加新的 jar
Kafka的类路径。在这之后我应该重新开始工作。
我不知道该怎么做才对,我想我们应该停下来跑掉。
但当我想阻止工人时,我不知道如何才能正确地做到这一点。当然,我可以通过 ps aux | grep worker
,杀死它并杀死我应该找到的rest服务器 ps
我也是。但我觉得情况很奇怪。杀死两个进程不是一个好主意,但我找不到任何信息我们可以用另一种方法来做。
如果你知道正确的方法,请帮助我:)
谢谢你的时间。
1条答案
按热度按时间hfyxw5xn1#
杀死两个进程不是个好主意
ConnectDistributed
只是一个过程。没有单独的rest服务器可以停止。是的,
:connector/pause
接着是一个kill <pid>
是阻止它的正确方法。如果与最新版本的confluent platform一起安装,则可以停止/开始使用
systemctl
.