安装kafka

mkdir /usr/local/kafka

cd /usr/local/kafka</pre>
tar -vxzf redis-3.2.10.tar.gz

cd kafka_2.11-2.0.0/config
vim zookeeper.properties

# 数据的存放目录
dataDir=/tmp/zookeeper
# 端口，默认就是2181
clientPort=2181

vim server.properties

# broker的全局唯一编号，不能重复
broker.id=0
# 监听
listeners=PLAINTEXT://10.168.1.213:9092
# 日志目录
log.dirs=/tmp/kafka-logs
# 配置zookeeper的连接（如果不是本机，需要该为ip或主机名）
zookeeper.connect=localhost:2181

cd  /usr/local/kafka/kafka_2.11-2.0.0

./bin/zookeeper-server-start.sh -daemon ./config/zookeeper.properties &

./bin/kafka-server-start.sh -daemon ./config/server.properties &

jps

cd /etc/init.d/

vim kafka

#!/bin/bash
#chkconfig:2345 20 90
#description:kafka
#processname:kafka

### BEGIN INIT INFO
# Required-Start:
# Required-Stop:
# Default-Start:        2 3 4 5
# Default-Stop:         0 1 6
# Short-Description:    kafka server
# Description:          kafka server.
### END INIT INFO


export JAVA_HOME=/usr/local/java/jdk1.8.0_181
export PATH=$JAVA_HOME/bin:$PATH

zookeeperStart(){
    /usr/local/kafka/kafka_2.11-2.0.0/bin/zookeeper-server-start.sh -daemon /usr/local/kafka/kafka_2.11-2.0.0/config/zookeeper.properties &
}

kafkaStart(){
    /usr/local/kafka/kafka_2.11-2.0.0/bin/kafka-server-start.sh -daemon /usr/local/kafka/kafka_2.11-2.0.0/config/server.properties &
}

zookeeperStop(){
    /usr/local/kafka/kafka_2.11-2.0.0/bin/zookeeper-server-stop.sh
}

kafkaStop(){
    /usr/local/kafka/kafka_2.11-2.0.0/bin/kafka-server-stop.sh
}
case $1 in
    start)
        echo -n "Starting Kafka:"
        zookeeperStart
        sleep 5
        kafkaStart
        exit $?
    ;;
    stop)
        echo -n "stop Kafka:"
        kafkaStop
        sleep 5
        zookeeperStop
        exit $?
    ;;
    status)
        jps
        exit $?
    ;;
    restart)
        echo "restart"
        stop
        sleep 5
        start
        exit $?
    ;;
    *)
    echo "require start|stop|status|restart"
    exit 1
    ;;
esac

chmod +x kafka 

update-rc.d -f kafka defaults

service kafka start

jps

reboot