Kafka消费出现异常

收藏
kafka
28
Feb 1, 2018

kakfa消费超时:

Caused by: 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

回答

铁木真回答

问题分析:

提交offset的时候,offset已经被修改过了,所以报这个错

问题答案:

设置为自动提交offset: enable.auto.commit=true

调整客户端session超时时间:session.timeout.ms =60000

(0)

提交成功