kafka安装

kafka_2.11-0-0.11.0.0.tgz

取3台机子

1. 解压到规定目录，如/opt/module/
2. 修改config文件

/opt/module/kafka/config
broker_id=1 注：为kafka节点编号
zookeeper.connect=node1:2181,node2:2181,node3:2181 注：为zookeeper地址

3. 3台节点分别启动

在启动zookeeper之后启动执行

/root/kafka/kafka_2.11-0.11.0.0/bin/kafka-server-start.sh -daemon /root/kafka/kafka_2.11-0.11.0.0/config/server.properties

4. 查看是否安装成功

jps

5. 创建topic

/root/kafka/kafka_2.11-0.11.0.0/bin/kafka-topics.sh --zookeeper 10.128.27.9:2181 --create --replication-factor 3 --partitions 1 --topic MDM_TEST

6. 查看topic

/root/kafka/kafka_2.11-0.11.0.0/bin/kafka-topics.sh --zookeeper 10.128.27.9:2181 --list

7. 关闭

/root/kafka/kafka_2.11-0.11.0.0/bin/kafka-server-stop.sh