kafka-python 无故停止消费

kafka-python 无故停止消费
kafka-python异常 环境是2副本6分区kafka主题,但是kafka-python无任何故障停止消费,导致超时触发rebalance 原因 具体原因未知,调试无任何错误日志,消费过程中就那么突然停止了。。。。。 解决方案 换成pykafka后解决。推荐使用balance多消费者(一消费者一分区) topic.get_balanced_consumer( consumer_group='groupId', auto_commit_enable=True, auto_commi...

kafka多线程消费异常

kafka多线程消费异常
kafka CommitFailedException rebalanced poll 问题: 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 ...
Copyright © C/C++程序员之家 保留所有权利.   Theme  Ality 浙ICP备15011757号-3

用户登录