要啟動Kafka命令行消費者,請按照以下步驟操作:
首先,確保已經安裝了Apache Kafka。如果尚未安裝,請訪問官方網站(https://kafka.apache.org/downloads)下載并安裝適合您操作系統的版本。
創建一個Kafka消費者組。在命令行中,使用以下命令創建一個新的消費者組(將your-group-id替換為您選擇的消費者組ID):
bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --create --group your-group-id
your-topic替換為您要訂閱的主題名稱,將your-group-id替換為您在第2步中創建的消費者組ID):bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic your-topic --from-beginning --group your-group-id
現在,您已經成功啟動了一個Kafka命令行消費者。它將連接到本地Kafka服務器(localhost:9092),并訂閱了指定的主題。消費者將從主題的開頭開始消費消息,并在控制臺中顯示它們。要停止消費者,請按Ctrl + C。