kafka集群搭建

1.    修改配置文件 server.properties
broker.id=1                        #三个kafka节点，id依次1、2、3,不能重复
zookeeper.connect=zk1_ip:12181,zk2_ip: 12181,zk3_ip:12181  #zookeeper集群节点的ip和端口

2.    将配置上传到kafka docker宿主机的/opt/kafka/config/目录。

3.    三个节点启动kafka 容器，
   bin/kafka-server-start.sh -daemon config/server.properties
    查看日志是否有报错信息。
    
4.    Listeners=PLAINTEXT://0.0.0.0:9092,SSL://0.0.0.0:9093。
    (若是容器就按照此配置，不是容器就填节点ip)
    
5.    检查kafka是否已经正常注册到zookeeper
    进入zookeeper容器内存，/opt/zookeeper/bin目录，
    sh zkCli.sh -server 127.0.0.1:2181                (端口根据实际情况)
    输入 get /brokers/ids/     按tab键，若是显示kafka所有节点id，说明kafka都已经注册成功。

查看主题
./kafka-topics.sh --list --zookeeper zk1_ip:2181
./kafka-topics.sh  --describe --zookeeper zk1_ip:2181   --topic kong-log