安装jdk

JDK版本大于1.8

安装kafka

tar -zxvf kafka_2.11-0.10.2.1.tgz

mv kafka_2.11-0.10.2.1 /usr/local/kafka

配置kafka

创建kafka日志目录

mkdir /data/kafkalogs

vi /usr/local/kafka/config/server.properties  

broker.id=0

port=9092

host.name=192.168.56.10

log.dirs=/data/kafkalogs

zookeeper.connect=localhost:2181

安装zookeeper

tar -zxvf zookeeper-3.4.10.tar.gz

mv zookeeper-3.4.10 /usr/local/zookeeper

配置zookeeper

mkdir /data/zookeeper

mkdir /data/zookeeperlogs

vi /usr/local/kafka/config/zookeeper.properties  

tickTime=2000

dataDir=/data/zookeeper

dataLogDir=/data/zookeeperlogs

clientPort=2181

initLimit=5

syncLimit=2

server.0=lgj01:2888:3888

创建启动kafka脚本 kafka_start.sh

#!/bin/sh

/usr/local/kafka/bin/zookeeper-server-start.sh /usr/local/kafka/config/zookeeper.properties &

sleep 3  

/usr/local/kafka/bin/kafka-server-start.sh /usr/local/kafka/config/server.properties &

创建关闭kafka脚本  kafka_stop.sh

#!/bin/sh

/usr/local/kafka/bin/zookeeper-server-stop.sh /usr/local/kafka/config/zookeeper.properties &

sleep 3

/usr/local/kafka/bin/kafka-server-stop.sh /usr/local/kafka/config/server.properties &