zoukankan      html  css  js  c++  java
  • 报错:Bootstrap broker basecoalmine:2181 (id: -1 rack: null) disconnected (org.apache.kafka.clients.NetworkClient)

    报错背景:

    新安装的单机版kafka启动消费者的时候报错!

    报错现象:

    [2020-05-19 22:08:04,053] WARN [Consumer clientId=consumer-console-consumer-36457-1, groupId=console-consumer-36457] Bootstrap broker basecoalmine:2181 (id: -1 rack: null) disconnected (org.apache.kafka.clients.NetworkClient)
    [2020-05-19 22:08:04,990] WARN [Consumer clientId=consumer-console-consumer-36457-1, groupId=console-consumer-36457] Bootstrap broker basecoalmine:2181 (id: -1 rack: null) disconnected (org.apache.kafka.clients.NetworkClient)
    [2020-05-19 22:08:06,086] WARN [Consumer clientId=consumer-console-consumer-36457-1, groupId=console-consumer-36457] Bootstrap broker basecoalmine:2181 (id: -1 rack: null) disconnected (org.apache.kafka.clients.NetworkClient)

    报错原因:

    端口号的问题,以前启动消费者的时候监听的端口是 2181,但是新版本的kafka对zookeeper的依赖没有那么强烈了,所以改成了自己的 9092。

    kafka-console-consumer.sh --bootstrap-server basecoalmine:2181 --topic test --from-beginning

    报错解决:

    修改端口号

    kafka-console-consumer.sh --bootstrap-server basecoalmine:9092 --topic test --from-beginning

     

  • 相关阅读:
    Js实现页面跳转的几种方式
    android给View设置上下左右边框
    mac下安装tomcat
    Series.str方法
    loc() iloc() at() iat()函数
    sudo: pip:找不到命令
    杀死进程方法
    unique()与nunique()
    object数据类型
    set_index()与reset_index()函数
  • 原文地址:https://www.cnblogs.com/chuijingjing/p/12920005.html
Copyright © 2011-2022 走看看