Akka 的 BroadcastHub 不会在特定数量的消费者连接后才开始消费上游内容。它会在创建时立即开始消费上游,并将所有接收到的数据广播给所有已连接的消费者。

如果您需要控制消费者的数量,即只有当达到特定数量的消费者连接后才开始消费上游内容,您可以考虑使用其他类型的流处理器,例如 MergeHub 或 PartitionHub。这些流处理器允许您更灵活地管理消费者数量和消费行为。

Akka BroadcastHub 是否支持指定消费者数量?

原文地址: https://www.cveoy.top/t/topic/lIIz 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录