1.tar包下載:https://www.apache.org/dyn/closer.cgi?path=/kafka/1.0.0/kafka_2.11-1.0.0.tgz
2.將tar包解壓縮? tar-xzf kafka_2.11-1.0.0.tgz
3.修改kafka默認(rèn)配置:server.properties(kafka_2.11-1.0.0/config 目錄下)
注意:此處主要是修改下zookeeper的集群地址,我這zookeeper是已經(jīng)安裝好的
3.啟動(dòng)kafka server:??
??????? >cd?? kafka_2.11-1.0.0
??????? >bin/kafka-server-start.sh config/server.properties
注意:如果是多臺(tái)機(jī)器,只需在每臺(tái)機(jī)器上啟動(dòng)kafka-server即可(要保證每臺(tái)機(jī)器上server.properties 中broker.id 是不同的)志电。
測試集群是否可用:
? 1.創(chuàng)建topic?
???? > bin/kafka-topics.sh --create --zookeeper spidercdh-01:2181 --replication-factor 1 --partitions 1 --topic test
??? 列出kafka中的topic > bin/kafka-topics.sh --list --zookeeper spidercdh-01:2181
? 2. 啟動(dòng)生產(chǎn)者客戶端(kafka帶有命令行的生成者和消費(fèi)者的客戶端):
???????????? >bin/kafka-console-producer.sh --broker-list spidercdh-01:9092 --topic test
3.啟動(dòng)消費(fèi)者客戶端:
????????? > bin/kafka-console-consumer.sh --bootstrap-server spidercdh-02:9092 --topic test --from-beginning
? 4.搭建結(jié)束(后臺(tái)啟動(dòng)? nohup bin/kafka-server-start.sh config/server.properties > /home/kafka_nohup.log 2>&1 &)