返回到文章

采纳

什么情况下kafka消费者组的状态会为dead死亡状态?如何避免?

kafka

用的kafka0.9客户端,kafka消费者组信息配置到代码配置文件里。

kafka集群部署到三个服务器上,每个服务器分别部署一个kafka和zookeeper。 集群有五个topic,每个topic一个partition。五个消费者组,一个消费者组里面有一个消费者。

消费端注解用的是@KafkaListener

问题描述:

刚启动消费,消费没有问题。过两天突然不消费了,扒日志发现报错,消费者组已经处于dead状态了。本地重新启动消费的时候,没有报错但是一直不能消费 扒服务器日志报一个错误:

Group renewalGroup generation 1 is dead and removed

而且每次启动时间和报错时间相差30秒,一个session.timeout.ms的时间。

目前只能换一个其他消费者组才能重新消费

我之前的消费者组怎么能接着使用?或者怎么样才能避免这种问题的发生?