用的kafka0.9
客户端,kafka消费者组信息配置到代码配置文件里。
kafka集群部署到三个服务器上,每个服务器分别部署一个kafka和zookeeper。 集群有五个topic,每个topic一个partition。五个消费者组,一个消费者组里面有一个消费者。
消费端注解用的是@KafkaListener
刚启动消费,消费没有问题。过两天突然不消费了,扒日志发现报错,消费者组已经处于dead状态了。本地重新启动消费的时候,没有报错但是一直不能消费 扒服务器日志报一个错误:
Group renewalGroup generation 1 is dead and removed
而且每次启动时间和报错时间相差30秒,一个session.timeout.ms
的时间。
目前只能换一个其他消费者组才能重新消费
我之前的消费者组怎么能接着使用?或者怎么样才能避免这种问题的发生?