Kafka 消费组是 Kafka 提供的可扩展且具有容错性的消费者机制。同一个消费组的多个消费者就能分布到多个物理机器上以加速消费,同时也可以实现负载均衡。
当某个消费者宕机时,其他消费者可以继续消费该分区的数据,从而保证了数据的可靠性和持久性。
特性
Kafka 消费组有以下特性:
- 同一个消费组内的多个消费者共享一个公共 ID。
- 消费组内的每个消费者都有自己的偏移量(offset)信息,用于记录已经消费过的消息位置。
- 消费组内的每个消费者都可以处理分区中的所有消息。
- 消费组内的每个消费者都可以处理分区中的所有消息。
- 消费组内的每个消费者都可以处理分区中的所有消息。
THE END
暂无评论内容