zoukankan      html  css  js  c++  java
  • kafka集群搭建

    1.    修改配置文件 server.properties
    broker.id=1                        #三个kafka节点,id依次1、23,不能重复
    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
  • 相关阅读:
    A
    B
    C
    I
    公共最大字串长度
    docker run 的背后的故事(zz)
    python之多并发socket(zz)
    Python垃圾回收机制:gc模块(zz)
    我要做的git的分享(zz)
    SpringMVC框架入门配置 IDEA下搭建Maven项目(zz)
  • 原文地址:https://www.cnblogs.com/kevincaptain/p/11855451.html
Copyright © 2011-2022 走看看