kafka運(yùn)行需要zookeeper、scala2.11歹鱼、jdk支撐
版本：kafka_2.11-0.10.0.1.tgz（2.11指的是scala版本泣栈，0.10.0.1才是kafka的版本）
簡(jiǎn)介：kafka是一個(gè)分布式消息中間件(現(xiàn)在改成分布式流平臺(tái))，主要就是用來(lái)緩存消息弥姻，供消費(fèi)者安全消費(fèi)南片，就像一個(gè)大池子，允許往池子里灌水（消息）庭敦，從池子里取水（但是這個(gè)水是不會(huì)減少的疼进，除非設(shè)定的消息時(shí)間到期了，由kafka自己刪除落得消息數(shù)據(jù)）
1秧廉、上傳安裝包到~/software/目錄
2伞广、解壓
tar -xzvf kafka_2.11-0.10.0.1.tgz? -C ../app/
3、創(chuàng)建數(shù)據(jù)目錄
mkdir? ~/app/kafka_2.11-0.10.0.1/logs
4疼电、修改kafka配置文件
vi? ~/app/kafka_2.11-0.10.0.1/config/server.properties
broker.id=1?? #kafka集群中的節(jié)點(diǎn)id嚼锄，不同節(jié)點(diǎn)采用不同的id
port=9092?? #kafka訪問(wèn)端口
host.name=192.168.137.141?? #kafka節(jié)點(diǎn)的ip
log.dirs=/home/hadoop/app/kafka_2.11-0.10.0.1/logs??? #kafka節(jié)點(diǎn)的數(shù)據(jù)目錄
zookeeper.connect=192.168.137.141:2181,192.168.137.142:2181,192.168.137.143:2181/kafka
注意：zk連接的kafka后綴，這個(gè)會(huì)在zk根目錄下新建kafka節(jié)點(diǎn)
5澜沟、設(shè)置環(huán)境變量
export KAFKA_HOME=/home/hadoop/app/kafka_2.11-0.10.0.1/
export PATH=$KAFKA_HOME/bin:$PATH
source /etc/profile
6灾票、啟動(dòng)kafka
nohup kafka-server-start.sh config/server.properties &
7、創(chuàng)建topic
bin/kafka-topics.sh --create \
--zookeeper 192.168.137.141:2181,192.168.137.142:2181,192.168.137.143:2181/kafka \
--replication-factor 3 --partitions 3 --topic test
8茫虽、啟動(dòng)生產(chǎn)者測(cè)試用例
bin/kafka-console-producer.sh \
--broker-list 192.168.137.141:9092,192.168.137.142:9092,192.168.137.143:9092 --topic test
9刊苍、另一個(gè)終端啟動(dòng)消費(fèi)者用例
bin/kafka-console-consumer.sh \
--zookeeper 192.168.137.141:2181,192.168.137.142:2181,192.168.137.143:2181/kafka \
--from-beginning --topic test
