玩弄Kafka

如果你只是想拿來當 Queue   這個功能就過之了

也可能沒這樣好用 裝個rabbitmq 可能會很好 還有比較好的介面使用


用conflunt 裝好 也啟動之後 就來 弄個 consumer吧

/bin 底下 有很多 執行 shell 可以使用

 ./kafka-console-consumer --bootstrap-server 127.0.0.1:9092 --from-beginning --topic TEST

--from-beginning  會從 0 開始 沒有offset

但是這樣會從 Topic Test裡面 拿出從古至今所有的 Data
如果不需要 就拿掉這段 就是一般的 先進先出 Queue


弄個 Producer吧

./kafka-console-producer --broker-list localhost:9092 --topic test

Standard Input 輸入幾個 Msg
另一編的 consumer 就收到訊息了
簡易的  KafKa 就 完成了