Kafka消费者突发停止监听问题求助(附相关日志)
Kafka消费者突发停止监听Topic问题求助
我的服务中有一个Kafka Consumer,负责监听某Topic的消息,该服务已稳定运行一年有余。但近两日,该Kafka Consumer出现两次停止监听Topic的异常情况,无法复现该问题,且并非每日发生,暂时无法定位原因,恳请有类似问题经验或了解原因的同行提供帮助。
异常日志
Group coordinator aefgh5h4g413682594h05bb135766b2b-16272c2g4566122c.elb.eu-west-1.amazonaws.com:9094 (id: 2147483645 rack: null) is unavailable or invalid due to cause: session timed out without receiving a heartbeat response.isDisconnected: false. Rediscovery will be attempted. Discovered group coordinator aefgh5h4g413682594h05bb135766b2b-16272c2g4566122c.elb.eu-west-1.amazonaws.com:9094 (id: 2147483645 rack: null)","logger_name":"org.apache.kafka.clients.consumer.internals.AbstractCoordinator Attempt to heartbeat with Generation{generationId=7, memberId='consumer-service-1-8f7d95c3-aa50-4a51-ab3d-c99aaece955d', protocol='range'} and group instance id Optional.empty failed due to UNKNOWN_MEMBER_ID, resetting generation Giving away all assigned partitions as lost since generation has been reset,indicating that consumer is no longer part of the group Lost previously assigned partitions kafka_topic-0 (Re-)joining group Offset commit failed on partition kafka_topic-0 at offset 2365944: The coordinator is not aware of this member. OffsetCommit failed with Generation{generationId=7, memberId='consumer-service-1-8f7d95c3-aa50-4a51-ab3d-c99aaece955d (Re-)joining group Member consumer-service-1-7c2f402c-7659-4c8b-aeab-f24d1b21d940 sending LeaveGroup request to coordinator aefgh5h4g413682594h05bb135766b2b-16272c2g4566122c.elb.eu-west-1.amazonaws.com:9094 (id: 2147483645 rack: null) due to the consumer is being closed Metrics scheduler closed Closing reporter org.apache.kafka.common.metrics.JmxReporter Metrics reporters closed App info kafka.consumer for consumer-service-1 unregistered
内容的提问来源于stack exchange,提问作者emir
相关产品推荐
相关产品推荐

