溫馨提示×

kafka命令行消費如何操作

小樊
117
2024-12-18 17:04:23
欄目: 大數據

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

0
亚洲午夜精品一区二区_中文无码日韩欧免_久久香蕉精品视频_欧美主播一区二区三区美女