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
參數才能消費消息隊列中的所有消息。如果不指定該參數,則只會消費最新的消息。