Kafka 2.0課程 9 Console Consumer CLI

Console Consumer CLI(Command Line Interface)

在學習執行相關指令前，請先確認Server啟動(或參考課程6)

Consumer關鍵指令為:

kafka-console-consumer

透過上述指令可以看到相關的doc

看到bootstrap-server是必要參數(即kafka伺服器)，另外可指定topic

試著下指令去接收前一課程輸入的訊息

kafka-console-consumer --bootstrap-server 127.0.0.1:9092 --topic first_topic

啥訊息都沒看到!!

因為consumer只接收當下的訊息!!

下面再多開一個terminal(左邊是consumer 右邊是producer)

Window作業系統左邊要按一下enter才會秀出右邊producer打得訊息

可以看到預設情況下consumer只接收新的producer拋來的訊息

但是我們一定會有需求想知道最初就存在的訊息

所以要加上--from-begining

kafka-console-consumer --bootstrap-server 127.0.0.1:9092 --topic first_topic --from-beginning

另外還可以看到如下圖訊息的排列順序

如同理論有提到只有單一個partition內可以保證排序

目前該topic內有三個partitions，除非今天是一個partition才能保證排序

參考課程