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