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

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

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

消费端注解用的是@KafkaListener

问题描述:

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

Group renewalGroup generation 1 is dead and removed

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

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

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






发表于: 5天前   最后更新时间: 4天前   游览量:78
上一条: 到头了!
下一条: 已经是最后了!

评论…


  • Group renewalGroup generation 1 is dead and removed,应该是info级别的日志吧。
    不太清楚你程序的设计,你可以先用命令来查看消费者订阅的情况,查看offset等。
    http://orchome.com/454
  • 评论…
    • in this conversation