为了连接strom和flink的的使用，选择了0.10.2.2版本的kafka。

一、下载，解压

地址：https://www.apache.org/dyn/closer.cgi?path=/kafka/0.10.2.2/kafka_2.12-0.10.2.2.tgz

解压指令：tar -zxvf kafka_2.10-0.8.2.2.tgz

二、修改配置

cd kafka_2.12-0.10.2.2/config/
vi server.propertie
mkdir /data/kafka-logs  #在需要的地方新建log文件夹

下面是要修改的几个位置

broker.id=1  #每个机器的ID都应该不同
delete.topic.enable=true #使用指令删除topic的时候直接删除
log.dirs=/home/xxxx/data/kafka-logs #log日记保存的地址
listeners=PLAINTEXT://XXXXX:9092  #XXX是每个机子的IP地址
zookeeper.connect=127.0.0.1:3000,127.0.0.1:3001,127.0.0.1:3002 #zookeeper的集群，格式Ip1：端口1，Ip2：端口2,······地址一般端口是2181

注意每个机器的配置文件都要修改，id和listeners的IP地址各不相同

三、启动kafka

./kafka_2.12-1.1.0/bin
./kafka-server-start.sh -daemon ../config/server.properties

使用jps查看启动情况

21380 Kafka
20316 QuorumPeerMain
23069 Jps

注意：QuorumPeerMain是zookeeper的进程，在启动kafka前需要先启动zookeeper

四、配置kafkamanager

在解压后的conf目录中打开 application.conf文件，修改其中的配置信息，最主要的内容为：

kafka-manager.zkhosts="10.11.6.52:2181,10.11.6.53:2181,10.11.6.54:2181"  #修改成自己的zookeeper集群地址

启动kafkamanager

nohup ./kafka-manager &
jps查看启动情况
26076 ProdServerStart

浏览器输入：启动机器IP:9000，如10.11.6.52:9000

配置集群

点击【Cluster】>【Add Cluster】打开如下添加集群的配置界面： 创建集群

1. 填写集群名称
2. 填写zookeeper集群地址
3. 选择kafka版本

注意如果没有在 Kafka 中配置过 JMX_PORT，千万不要选择第一个复选框Enable JMX Polling

如下配置修改bin/kafka-server-start.sh，添加JMX_PORT参数，添加后样子如下

if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then
    export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G"
    export JMX_PORT="9999"  #加入这条
fi

从Brokers中可以查看启动的kafka数目是否正常

Brokers信息

还可以直接在网页中创建topic等操作，查看broker的消费信息。