0

私はApache Kafkaを初めて使用しており、トピックからのメッセージを消費しようとしています。私は、メッセージを参照するには、コンソールから次を実行しました:Apache Kafka Consumer - コンソールから終了

bin\windows\kafka-console-consumer.bat --zookeeper localhost:2181 --topic test --from-beginning 

をしかし、その後、私は消費者は、「コンソール・消費者-4158」と呼ばれ、私は誤ってコンソールを閉じて作成されて見ることができました。

実行中のコンシューマを終了するにはどうすればよいですか?

答えて

0
  1. 消費者を終了すると、プロセス自体が停止します。
  2. 古いコンシューマAPIを使用しているので、groupId(console-consumer-4158)+消費されたオフセットに関する情報はzookeeperに保存されています。未使用のグループを自動的に削除するプロセスはありません(see more
+0

これは私の質問です。消費者はどのように解雇されるのか、または終わりからどのように解雇されるのか? –

+0

コンソールコンシューマは単純なJavaプロセスです。コンソールを閉じると、プロセスは自動的に終了します – Natalia

関連する問題