4.2. 使用消费者组扩展数据消耗
用户组共享一个通常由来自给定主题的一个或多个制作者生成的大型数据流。消费者使用 group.id
属性分组,允许消息分散到成员中。组中的一个消费者被选为领导机,决定如何将分区分配给组中的消费者。每个分区只能分配给一个消费者。
如果您还没有作为分区的用户数量,您可以通过添加具有相同 group.id
的更多消费者实例来扩展数据消耗。在组中添加比分区更多的消费者将有助于吞吐量,但这意味着在待机上有消费者能够停止工作。如果您可以使用较少的使用者达到吞吐量目标,您可以节省资源。
同一消费者组中的消费者发送偏移提交和心跳到同一代理。消费者向 Kafka 代理发送心跳,以指示其在消费者组中的活动。因此组中消费者的数量越大,代理上的请求负载越高。
... ...
# ...
group.id=my-group-id
# ...
- 1
- 使用组 ID 将消费者添加到消费者组中。