1. 解壓kafka_2.10-0.9.0.1.tgz至指定目錄

[root@node02 software]# tar -zvxf kafka_2.10-0.9.0.1.tgz -C /opt/ycyz/

2. 打開Kafka安裝目錄下的config目錄修改配置文件server.properties 配置zookeeper集群地址

[root@node02 config]# vi server.properties 
zookeeper.connect=node02:2181,node03:2181,node04:2181

3. 將Kafka目錄分發(fā)到其他節(jié)點

4. 修改每個節(jié)點對應(yīng)server.properties文件的broker.id，node02、node03、node04對應(yīng)的id分別為0、1、2

5. 配置環(huán)境變量

6. 啟動Kafka集群

[root@node02 ~]# kafka-server-start.sh $KAFKA_HOME/config/server.properties

基礎(chǔ)使用

（kafka-topics.sh --help查看幫助手冊）

• 創(chuàng)建topic：

kafka-topics.sh --zookeeper node02:2181,node03:2181,node04:2181 --create --replication-factor 2 --partitions 3 --topic test

（參數(shù)說明：
--replication-factor：指定每個分區(qū)的復(fù)制因子個數(shù)，默認(rèn)1個
--partitions：指定當(dāng)前創(chuàng)建的kafka分區(qū)數(shù)量，默認(rèn)為1個
--topic：指定新建topic的名稱）

• 查看topic列表：

kafka-topics.sh --zookeeper node02:2181,node03:2181,node04:2181 --list

• 查看“test”topic描述：

kafka-topics.sh --zookeeper node02:2181,node03:2181,node04:2181 --describe --topic test

• 創(chuàng)建生產(chǎn)者：

kafka-console-producer.sh --broker-list node02:9092,node03:9092,node04:9092 --topic test

• 創(chuàng)建消費(fèi)者：

kafka-console-consumer.sh --zookeeper node02:2181,node03:2181,node04:2181 --from-beginning --topic test

注：
查看幫助手冊：
bin/kafka-console-consumer.sh help