Akka 的 BroadcastHub 是否支持在有指定个消费者时再开始消费他的上游?如果不支持,我想要提交一个 Pull Request 让它支持,您觉得 BroadcastHub 这个类的构造函数应该如何修改?

进一步了解了您的问题后,我发现您想要实现的功能是在有指定个消费者时再开始消费上游,而不是在所有消费者都连接时开始消费。目前,BroadcastHub 不支持此功能。

如果您想提交一个 Pull Request 来实现此功能,您需要修改 BroadcastHub 的源代码并添加新的构造函数或其他方法来支持此功能。您可以在 BroadcastHub 中添加一个参数,以指定有多少个消费者时才开始消费上游。这个参数可以是可选的,这样用户可以选择在所有消费者都连接时开始消费,或者在达到指定数量的消费者时开始消费。

您可以在 Akka GitHub 存储库中找到 BroadcastHub 的源代码并开始修改。在提交 Pull Request 之前,请确保您的修改经过了充分的测试,并且遵循 Akka 社区的代码规范和最佳实践。

希望这可以帮助您实现您的功能,并为 Akka 社区做出贡献!

Akka BroadcastHub 支持指定消费者数量开始消费上游吗?

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

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