zoukankan      html  css  js  c++  java
  • kafka消息异常处理CommitFailedException

    1、 异常信息

    org.apache.kafka.clients.consumer.CommitFailedException: Commit cannot be completed since the group has already rebalanced and assigned the partitions to another member. This means that the time between subsequent calls to poll() was longer than the configured max.poll.interval.ms, which typically implies that the poll loop is spending too much time message processing. You can address this either by increasing max.poll.interval.ms or by reducing the maximum size of batches returned in poll() with max.poll.records.
    

    2、 异常解决

    a)调大max.poll.interval.ms,默认300000ms(300s)
    b)调小max.poll.records,默认500
    c)另起线程
    
    记录学习和生活的酸甜苦辣.....哈哈哈
  • 相关阅读:
    小白的进阶之路7
    小白的进阶之路6
    小白的进阶之路5
    小白的进阶之路4
    小白的进阶之路3
    小白的进阶之路2
    小白的进阶之路1
    02CSS布局13
    02css定位12
    02css盒子模型11
  • 原文地址:https://www.cnblogs.com/yjt1993/p/14292613.html
Copyright © 2011-2022 走看看