一、准备

　 1. 三台虚拟机

　 2. zookeeper环境

　 3. java 环境

 

二、 下载安装文件并解压

wget http://mirror.bit.edu.cn/apache/kafka/2.0.1/kafka_2.11-2.0.1.tgz

　

tar -zxvf kafka_2.11-2.0.1.tgz mv kafka_2.11-2.0.1/ kafka

　　

三、修改配置

　　配置文件地址 ：config/server.properties

　　不同机器的 broker.id 和 listeners 需要根据不同的机器单独配置

　　

broker.id=1listeners=PLAINTEXT://192.168.0.110:9092log.dirs=/usr/local/kafka/log/zookeeper.connect=192.168.0.110:2181,192.168.0.111:2181,192.168.0.112:2181delete.topic.enable=true

 

四、修改环境变量

　　vim /etc/profile

## kafkaexport KAFKA_HOME=/usr/local/kafkaexport PATH=$KAFKA_HOME/bin:$PATH

　

五、启动

nohup bin/kafka-server-start.sh config/server.properties >/dev/null 2>&1 &