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
  • 相关阅读:
    JVM——类加载
    Java IO输入输出
    核心标签库和el
    request对象
    安装tomcat
    安装mongodb
    MySQL在简单命令行操作
    安装MySQL
    Java几种常见的异常类型
    Java简单正则表达式写爬虫
  • 原文地址:https://www.cnblogs.com/kevincaptain/p/11855451.html
Copyright © 2011-2022 走看看