kafka集群
<h4>1.下载地址</h4>
<p>（1） kafka.apache.org/downloads.html
（2） <a href="http://zookeeper.apache.org/releases.html">http://zookeeper.apache.org/releases.html</a>
（3）java版本1.8.161以上</p>
<h4>2.安装zookeeper</h4>
<p>（1）host文件写入集群主机名
cat /etc/hostname
vi /etc/hostname
<img src="http://nxsec.nxin.com/wiki/server/../Public/Uploads/2020-07-23/5f1936dde29a0.png" alt="" />
mkdir /usr/local/src
tar -zxvf zookeeper
创立软连接：ln -sv /usr/local/src/zookeeper-3.4.11 /usr/local/zookeeper
创立数据目录:mkdir /usr/local/zookeeper/data
复制配置文件：cp/usr/local/zookeeper/conf/zoo_sample.cfg /usr/local/zookeeper/conf/zoo.cfg
查看配置：grep "^[a-Z]" /usr/local/zookeeper/conf/zoo.conf
<img src="http://nxsec.nxin.com/wiki/server/../Public/Uploads/2020-07-23/5f193d2971c0d.png" alt="" />
三个节点myid要不一样。Echo 1 2 3
<img src="http://nxsec.nxin.com/wiki/server/../Public/Uploads/2020-07-23/5f193d37a54c8.png" alt="" />
启动 zookeeper
/usr/local/zookeeper/bin/zkServer.sh start
查看状态：
/usr/local/zookeeper/bin/zkServer.sh status</p>
<h4>3.安装kafka</h4>
<p>tar -zxvf kafka.tgz
创立软连接：
ln -sv /usr/local/src/kafka-2.11-1.00 /usr/local/kafka
更改配置文件：
vi /usr/local/kafka/config/server.properties
broker.id=1:id值每台服务器要不一样。
<img src="http://nxsec.nxin.com/wiki/server/../Public/Uploads/2020-07-23/5f19473e379ec.png" alt="" />
验证配置：grep "^[a-Z]" /usr/local/kafka/config/server.properties
启动kafka
/usr/local/kafka/bin/kafka-server-start.sh -daemon /usr/local/kafka/config/server.properties
查看kafka安装日志
tail /usr/local/kafka/logs/server.log
查看kafka topics详情：
/usr/local/kafka/bin/kafka-topics.sh --describe --zookeeper 172.16.200.247:2181,172.16.200.244:2181,172.16.200.212:2181 --topic test
获取 topic列表
/usr/local/kafka/bin/kafka-topics.sh --list --zookeeper 172.16.200.247:2181,172.16.200.244:2181,172.16.200.212:2181 </p>