Kafka 命令行消费可以通过以下步骤进行:
kafka-topics.sh --list --zookeeper <zookeeper-host:port>
如果返回了 Kafka 主题列表,说明已经安装成功。
<consumer-group-id>
替换为你想要的消费者组 ID:kafka-consumer-groups.sh --bootstrap-server <kafka-broker-host:port> --describe --group <consumer-group-id>
kafka-console-consumer.sh
命令行工具消费消息。将 <kafka-broker-host:port>
替换为 Kafka 代理地址,将 <topic>
替换为要消费的主题名称。例如:kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my-topic
这将启动一个消费者,订阅指定的主题并实时消费消息。按 Ctrl+C
停止消费者。
注意:如果你想要持续消费消息,可以添加 --from-beginning
参数,这将从头开始消费指定主题的所有消息:
kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my-topic --from-beginning
这就是如何使用 Kafka 命令行工具进行消费。希望对你有所帮助!