阅读量:87
Kafka 命令行消费可以通过以下步骤进行:
- 首先,确保已经安装了 Kafka 和相应的客户端工具。在终端中输入以下命令来检查是否已经安装:
kafka-topics.sh --list --zookeeper
如果返回了 Kafka 主题列表,说明已经安装成功。
- 创建一个消费者组。在终端中输入以下命令,将
替换为你想要的消费者组 ID:
kafka-consumer-groups.sh --bootstrap-server --describe --group
- 使用
kafka-console-consumer.sh命令行工具消费消息。将替换为 Kafka 代理地址,将替换为要消费的主题名称。例如:
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 命令行工具进行消费。希望对你有所帮助!