java - kakfa Consumer can't rebalance after 5 retries

 360691894_8a5c48 发布于 2022-10-29 01:45

JavaAPI中Kafka的消费者不能正确的连接到服务器的Kafka的队列。百度、google了很多都无法解决。

这是配置信息:

        props.put("zookeeper.connect", "XXXXXX:2181");
        //配置Zookeeper连接超时间隔
        props.put("zookeeper.connection.timeout.ms", "1000000");
        //配置Zookeeper的组id(The ‘group.id’ string defines the Consumer Group this process is consuming on behalf of.)
        props.put("group.id", "test-group");

        props.put("zookeeper.session.timeout.ms", "4000");
        props.put("zookeeper.sync.time.ms", "10000");
        props.put("auto.commit.interval.ms", "1000");

        props.put("rebalance.max.retries", "5");
        props.put("rebalance.backoff.ms", "1200");

这是错误日志:

Exception in thread "Thread-0" kafka.common.ConsumerRebalanceFailedException: test-group_yanyongdeMacBook-Pro.local-1471403173076-d34ac5a3 can't rebalance after 5 retries
    at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:660)
    at kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$reinitializeConsumer(ZookeeperConsumerConnector.scala:967)
    at kafka.consumer.ZookeeperConsumerConnector.consume(ZookeeperConsumerConnector.scala:254)
    at kafka.javaapi.consumer.ZookeeperConsumerConnector.createMessageStreams(ZookeeperConsumerConnector.scala:84)
    at kafka.javaapi.consumer.ZookeeperConsumerConnector.createMessageStreams(ZookeeperConsumerConnector.scala:96)
    at com.yany.consumer.ConsumerTest$MyConsumer.run(ConsumerTest.java:44)
2 个回答
  • ping talent 分别测试一下看通不通,配置没问题

    2022-11-12 01:44 回答
  • 初步认定为kafka版本和服务器端安装Zookeeper版本不兼容导致。我本地使用的kafka是0.9.0.0的版本,换成0.9.0.1的版本就可以用了

    2022-11-12 01:44 回答
撰写答案
今天,你开发时遇到什么问题呢?
立即提问
热门标签
PHP1.CN | 中国最专业的PHP中文社区 | PNG素材下载 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有