kafka命令行消费如何操作

Kafka 命令行消费可以通过以下步骤进行操作：

1. 确保已经安装了 Kafka，并且已经启动了一个或多个 Kafka broker 和一个 Zookeeper 服务。
2. 创建一个消费者组，可以使用 kafka-consumer-groups.sh 工具来创建。例如，创建一个名为 my-group 的消费者组：

bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --create --group my-group

3. 使用 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 参数才能消费消息队列中的所有消息。如果不指定该参数，则只会消费最新的消息。