如何正确重启kafka服务器?

Zei*_*van 8 apache-kafka apache-zookeeper

每次我停止kafka服务器并重新启动时,它都无法正常启动,因此我必须重新启动整个计算机并启动kafka服务器。有人知道我可以在不重新启动机器的情况下重新启动kafka服务器吗?实际上,我想终止上一个会话的使用者。

谢谢,

Zeinab

Gio*_*ous 9

如果您的Kafka经纪人正在/lib/systemd/system/从Confluent Platform的最新发行版中作为服务运行(位于下),则可以使用以下命令停止该服务:

systemctl stop confluent-kafka.service
Run Code Online (Sandbox Code Playgroud)

或者,如果您想重新启动服务,

systemctl restart confluent-kafka.service
Run Code Online (Sandbox Code Playgroud)

否则,您可以使用

./bin/kafka-server-stop.sh
Run Code Online (Sandbox Code Playgroud)

并重新启动它:

./bin/kafka-server-start.sh config/server.properties
Run Code Online (Sandbox Code Playgroud)

如果要停止特定使用者,只需找到相应的进程ID:

ps -ef | grep consumer_name
Run Code Online (Sandbox Code Playgroud)

并终止该过程:

kill -9 process_id
Run Code Online (Sandbox Code Playgroud)


Mat*_*ari 6

或者简单地:

sudo systemctl restart kafka
Run Code Online (Sandbox Code Playgroud)