Kafka 命令行消费可以通过以下步骤进行操作:
kafka-consumer-groups.sh
工具来创建。例如,创建一个名为 my-group
的消费者组:bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --create --group my-group
kafka-console-consumer.sh
工具来消费消息。例如,从名为 my-topic
的主题中消费消息,并将输出保存到控制台中:bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my-topic --from-beginning --group my-group
这个命令将从消息队列的开头开始消费消息,并将它们输出到控制台中。如果要停止消费,可以按 Ctrl+C
。
注意:在使用 kafka-console-consumer.sh
工具时,需要指定 --from-beginning
参数才能消费消息队列中的所有消息。如果不指定该参数,则只会消费最新的消息。