【資源】 http://www.cnblogs.com/likehua/p/3999538.html
準(zhǔn)備工作：kafka的運行需要依賴java和zookeeper，所以要提前準(zhǔn)備java和zookeeper環(huán)境，另外就是kafka的tar包了
【1】解壓
tar -xzvf kafka-0.9.2.tar.gz
mv kafka-0.9.2 /usr/local/
【2】配置環(huán)境變量
export KAFKA_HOME=/usr/local/kafka-0.9.2
export PATH = $KAFKA_HOME/bin:$PATH
【3】安裝啟動
#先啟動kafka自帶的zookeeper(當(dāng)然這里也可以啟動自己安裝的zookeeper)
./zookeeper-server-start.sh -daemon ../config/zookeeper.properties
#啟動kafka服務(wù)
./kafka-server-start.sh -daemon ../config/server.properties
#創(chuàng)建一個主題
./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic ARF
#創(chuàng)建一個消費者
./kafka-console-consumer.sh --zookeeper localhost:2181 --topic ARF --from-beginning
#創(chuàng)建一個新消費者（支持0.9版本+）
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic ARF --new-consumer --from-beginning --consumer.config ../config/consumer.properties
#創(chuàng)建一個生產(chǎn)者
./kafka-console-producer.sh --broker-list localhost:9092 --topic ARF
#創(chuàng)建一個新生產(chǎn)者（支持0.9版本+）
./kafka-console-producer.sh --broker-list localhost:9092 --topic ARF --producer.config ../config/producer.properties
相關(guān)命令請瀏覽：http://orchome.com/454
kafka基本語法.png
生產(chǎn)與消費.png
