消费者失败后，Kafka组重新平衡。org.apache.kafka.clients.consumer.internals.ConsumerCoordinator

消费者失败后，Kafka组重新平衡是指在Kafka消息队列中，当一个消费者节点发生故障或者失效时，Kafka会自动进行重新平衡，将该消费者节点上的分区重新分配给其他正常工作的消费者节点，以保证消息的可靠消费和高可用性。

具体来说，当一个消费者节点失败后，Kafka集群中的ConsumerCoordinator会接收到该节点的故障信息。ConsumerCoordinator是Kafka消费者组的协调者，负责管理消费者组的成员和分配分区。它会根据消费者组的配置和策略，重新计算分区的分配方案，并将新的分区分配方案通知给其他正常工作的消费者节点。

在重新平衡过程中，ConsumerCoordinator会考虑消费者节点的负载情况、消费进度以及分区的副本分布等因素，以实现负载均衡和数据的高可用性。重新平衡完成后，消费者组中的每个消费者节点会被分配到一定数量的分区，从而继续进行消息的消费。

对于消费者失败后的重新平衡，腾讯云提供了一系列相关产品和服务，如腾讯云消息队列 CKafka。CKafka是腾讯云提供的高可用、高吞吐量、分布式的消息队列服务，基于Apache Kafka开源项目构建。CKafka提供了自动的消费者组管理和分区分配机制，能够自动处理消费者节点的故障和重新平衡，确保消息的可靠消费和高可用性。

更多关于腾讯云CKafka的信息和产品介绍，可以参考腾讯云官方网站的相关页面：CKafka产品介绍。