zoukankan      html  css  js  c++  java
  • kafka调试遇到的问题

    在三台机器上以不同的端口部署了三个kafka和zookeeper实例,对应三套环境。

    如:

    zk1:2181

    zk2:2182

    zk3:2183

    kafka1:9092

    kafka2:9093

    kafka3:9094

    中午打开dev环境准备调个东西发现,producer能发出消息,但consumer收不到消息。

    各种排查:

    1. kafka版本匹配。

    2. 命令行用kafka producer发、kafka consumer收。

    3. 重建topic,换成其他topic。

    4. 查看日志。

    都正常,就是java应用consumer收不到。郁闷啊,头疼痛啊。。

    到快下班了,突然发现是consumer的brokers IP写错了。。。原来改环境、排查问题只注意端口了没注意IP。晕啊,浪费一个下午。

    还有一个问题:

    为什么命令行producer发消息时发到brokers。收消失从zookeeper收。

    但是java spring配置consumer也应该是从zookeeper收才对啊,但是只能从brokers收,为什么呢?

  • 相关阅读:
    寒假作业3:简化电梯优化
    线段树2
    线段树1
    数字游戏(二)
    P1352 没有上司的舞会
    加分二叉树
    数字转换
    BLO-Blockade
    树上倍增法求LCA
    种西瓜
  • 原文地址:https://www.cnblogs.com/kisf/p/8253096.html
Copyright © 2011-2022 走看看