Kafka:谁负责维护消费者群体读取偏移量消息的上限？

Kafka是一个分布式流处理平台，由Apache软件基金会开发和维护。在Kafka中，消费者群体的读取偏移量消息的上限由消费者自身负责维护。

Kafka通过使用消费者组的概念来管理消费者群体。消费者组是一组具有相同group.id的消费者的集合。每个消费者在消费消息时都会维护自己的读取偏移量，即消费者已经消费到的消息的位置。消费者群体的读取偏移量消息的上限是由每个消费者在消费消息时自行维护的。

当消费者从Kafka的分区中读取消息时，它会将读取的偏移量提交给Kafka集群。Kafka会将这个偏移量保存在内部的__consumer_offsets主题中。这个主题由Kafka自身维护，用于存储消费者群体的读取偏移量信息。

消费者可以定期提交偏移量，以确保它们的读取进度得到保存。如果消费者发生故障或重新加入消费者组，它可以从之前提交的偏移量处继续消费消息，而不会重复消费已经处理过的消息。

总结起来，Kafka中的消费者群体读取偏移量消息的上限由消费者自身负责维护，并通过提交偏移量到Kafka集群来保存读取进度。