安装kafka

1，下载kafka.

#cd /usr/local

#wget wget https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.1.1/kafka_2.11-2.1.1.tgz

解压安装包

#tar -zxvf kafka_2.11-2.1.1.tgz

更改安装包的名称。

# mv kafka_2.11-2.1.1 kafka

2，配置kafka。

创建log文件夹。

#cd /usr/local/kafka

# mkdir -pv /usr/local/kafka/log/kafka

修改/usr/local/kafka/config/目录下的配置文件

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

port=9092 #端口号
log.dirs=/usr/local/kafka/log/kafka #日志存放路径，上面创建的目录

3，配置kafka允许客户端可以远程连接。

把listeners=PLAINTEXT://:9092的注释去掉

把#advertised.listeners=PLAINTEXT://your.host.name:9092的注释也去掉，同时修改自己正确的IP地址，如 advertised.listeners=PLAINTEXT://52.82.102.211:9092

配置zookeeper:
mkdir /usr/local/kafka/zookeeper    #创建zookeeper目录

mkdir /usr/local/kafka/log/zookeeper  #创建zookeeper日志目录

cd /usr/local/kafka/config           #进入配置目录

vi zookeeper.properties          #编辑修改相应的参数

dataDir=/usr/local/kafka/zookeeper #zookeeper数据目录

dataLogDir=/usr/local/kafka/log/zookeeper #zookeeper日志目录

clientPort=2181

maxClientCnxns=100

tickTime=2000

initLimit=10

syncLimit=5

:wq! #保存退出

4，启动服务。

需要以守护进程方式运行（加了-daemon），不然关闭终端后kafka和zookeeper自动停止。

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

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

关闭服务。

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

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

如果还是无法停止服务，使用kill -9