4.2. 使用消费者组扩展数据消耗
消费者组共享由来自给定主题的一个或多个制作者生成的大型数据流。用户使用 group.id 属性分组,允许消息分散到成员中。组中的一个消费者是选择的领导者,决定如何将分区分配给组中的消费者。每个分区只能分配给单个消费者。
如果您还没有尽可能多的消费者分区,您可以通过添加更多具有相同 group.id 的消费者实例来扩展数据消耗。向组添加更多使用者无法帮助吞吐量,但这意味着有一个处于待机状态的用户应该有一个停止正常运行。如果可以通过较少的消费者来满足吞吐量目标,您可以节省资源。
同一消费者组中的消费者将偏移提交和心跳发送到同一代理。因此,组中的消费者数量越大,代理的请求负载越大。
... ...
# ...
group.id=my-group-id
# ...
- 1
- 使用组 ID 将消费者添加到消费者组中。