账号密码登录
微信安全登录
微信扫描二维码登录

登录后绑定QQ、微信即可实现信息互通

手机验证码登录
找回密码返回
邮箱找回 手机找回
注册账号返回
其他登录方式
分享
  • 收藏
    X
    kafka consumer 突然不消费
    41
    0

    kafka客户端用来消费日志数据,有两个机器消费。但是经常性的消费一会儿,就不消费了,zk上没有节点了,服务没有停,没有抛异常资源也足够了,但就是莫名其妙zk断了。还有几次是压根没起来,在连接zk那一步就卡住了。

    更奇怪的是,两个机器,我启动一台,另一台就起不来,有时候另一台起来了,第一台又死了,感觉这俩消费者好像是互斥的一样。

    我的配置是这样的:

    group.id = group_houtai_logcenter-es1
    zookeeper.connect = 10.37.8.54:2181,10.37.8.55:2181,10.37.8.56:2181
    zookeeper.session.timeout.ms = 40000
    zookeeper.sync.time.ms = 200
    auto.commit.interval.ms = 1000

    fetch.message.max.bytes=10485760

    compression.codec = 0
    serializer.class = kafka.serializer.StringEncoder

    partitions.count = 4

    consumer.count = 2

    rebalance.max.retries = 10
    rebalance.backoff.ms = 50000

    很疑惑,求解答

    0
    打赏
    收藏
    点击回答
        全部回答
    • 0
    • 一只鹿ii 普通会员 1楼
      502 Bad Gateway

      502 Bad Gateway


      nginx
    更多回答
    扫一扫访问手机版
    • 回到顶部
    • 回到顶部