apache-kafka - 如何正确重启kafka服务器？

Question

每次我停止 kafka 服务器并再次启动它时，它都无法正常启动，我必须重新启动整个机器并启动 kafka 服务器。
有人知道如何重新启动 kafka 服务器而不必重新启动我的机器吗？
实际上我想从上次 session 中终止消费者。

谢谢，

泽纳布

Answer 1

如果您的 Kafka 代理作为服务运行(位于 /lib/systemd/system/ 下)来自最近的 Confluent Platform 版本，您可以使用以下命令停止它:

systemctl stop confluent-kafka.service

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

systemctl restart confluent-kafka.service

否则，您可以停止您的经纪人使用

./bin/kafka-server-stop.sh

并重新启动它:

./bin/kafka-server-start.sh config/server.properties

如果要停止特定的消费者，只需找到相应的进程 id:

ps -ef | grep consumer_name

并杀死该进程:

kill -9 process_id