安装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 &