是的,这是可能发生的。因为BroadcastHub是一个异步的操作,它将每个元素广播到所有订阅的Sink中,但是无法保证每个Sink都能及时接收到每个元素。这取决于每个Sink的处理速度,以及它们之间的网络延迟等因素。因此,如果您需要确保每个Sink都接收到相同的元素,您可能需要实现自己的同步机制,例如使用分布式锁或消息队列。

akka的broadcasthub,同时订阅两个sink,可能收不到同样的元素

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

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