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目录分发到其他节点
4. 修改每个节点对应server.properties文件的broker.id，node02、node03、node04对应的id分别为0、1、2
5. 配置环境变量
6. 启动Kafka集群%7D)
[root@node02 ~]# kafka-server-start.sh $KAFKA_HOME/config/server.properties
基础使用
（kafka-topics.sh --help查看帮助手册）
-
创建topic：
kafka-topics.sh --zookeeper node02:2181,node03:2181,node04:2181 --create --replication-factor 2 --partitions 3 --topic test
（参数说明：
--replication-factor：指定每个分区的复制因子个数，默认1个
--partitions：指定当前创建的kafka分区数量，默认为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
-
创建生产者：
kafka-console-producer.sh --broker-list node02:9092,node03:9092,node04:9092 --topic test
-
创建消费者：
kafka-console-consumer.sh --zookeeper node02:2181,node03:2181,node04:2181 --from-beginning --topic test
注：
查看帮助手册：
bin/kafka-console-consumer.sh help
