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 命令行工具進行消費。希望對你有所幫助!