每次我停止Kafka服务器,并再次启动它不能正常启动,我必须重新启动我的整个机器,并启动Kafka服务器。有人知道我怎样才能重新启动Kafka服务器而不必重新启动我的机器吗?实际上,我想终止上次会话的消费者。谢谢您,泽纳布
xam8gpfp1#
或者简单地说:
sudo systemctl restart kafka
zd287kbt2#
如果您的kafka代理作为服务运行(在 /lib/systemd/system/ )从最近的confluent platform版本中,您可以使用以下方法阻止它:
/lib/systemd/system/
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
2条答案
按热度按时间xam8gpfp1#
或者简单地说:
zd287kbt2#
如果您的kafka代理作为服务运行(在
/lib/systemd/system/
)从最近的confluent platform版本中,您可以使用以下方法阻止它:或者如果你想重新启动服务,
否则,你可以阻止你的经纪人使用
重新启动:
如果要停止特定使用者,只需找到相应的进程id:
结束这个过程: