Kafka 簡介
作為一個(gè)消息中間件卧斟,Kafka 以高擴(kuò)展性、高吞吐量等特點(diǎn),在互聯(lián)網(wǎng)項(xiàng)目中被廣泛采用皂贩。
不清楚 Kafka 的同學(xué),可以先看看這篇文章:
http://blog.csdn.net/suifeng3051/article/details/48053965
部署 Kafka
為了方便初學(xué)者能快速試用 Kafka 昆汹,本文演示了如何用 Docker 快速部署一個(gè)簡單的 Kafka 服務(wù)明刷。
下載 kafka 的 docker 鏡像:
docker pull spotify/kafka
注意: kafka 依賴 zookeeper 服務(wù),而 spotify/kafka 里面集成好了 zookeeper 與 kafka满粗,實(shí)現(xiàn)了一鍵啟動(dòng)辈末。在 docker 中啟動(dòng) kafka 服務(wù):
docker run -p 2181:2181 -p 9092:9092 --env ADVERTISED_HOST=127.0.0.1 --env ADVERTISED_PORT=9092 spotify/kafka執(zhí)行 kafka 的生產(chǎn)端、消費(fèi)端程序,查看運(yùn)行效果:
下載 kafka 安裝包:
http://kafka.apache.org/downloads
下載完后解壓縮挤聘,進(jìn)入目錄中轰枝。
生產(chǎn)端發(fā)消息,命令行演示如下:
bin/kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic test
消息端收消息组去,命令行演示如下:
bin/kafka-console-consumer.sh --zookeeper 127.0.0.1:2181 --topic test --from-beginning