這一節(jié)咱們主要是討論單機(jī)版的Kafka的簡(jiǎn)單使用途乃，關(guān)于集群方面的東西其實(shí)也非常簡(jiǎn)單乖仇，具體可以參考Kafka官網(wǎng)進(jìn)行配置既可。
1规哲、準(zhǔn)備Zookeeper環(huán)境
我們使用的是zookeeper-3.5.0版本跟啤。
使用./zkServer.sh start命令啟動(dòng)Zookeeper
使用ps -ax | grep zookeeper命令，出現(xiàn)下圖所示：
2唉锌、準(zhǔn)備Kafka環(huán)境
我們使用的是kafka_2.10-0.8.2.1版本隅肥。
修改config/server.properties文件
找到host.name設(shè)置為127.0.0.1
啟動(dòng)Kafka服務(wù) ?./kafka-server-start.sh -daemon ../config/server.properties
創(chuàng)建Kafka的topic
./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic testKJ1啟動(dòng)Kafka consumer監(jiān)控端
./kafka-console-consumer.sh -zookeeper localhost:2181 --from-beginning --topic testKJ1
3、編寫JAVA Producer代碼
啟動(dòng)如下代碼：
4糊秆、Kafka consumer控制臺(tái)
可以看到下圖在consumer端不斷的滾動(dòng)producer發(fā)送來的數(shù)據(jù)。
本節(jié)我們介紹了Kafka的使用基礎(chǔ)议双，為我們正式進(jìn)行源碼分析打下了基礎(chǔ)痘番，在下一節(jié)中，咱們正式開始進(jìn)行Kafka的源碼分析之路平痰。
