Akka BroadcastHub:同步订阅两个Sink可能导致元素丢失问题
是的,在使用Akka BroadcastHub时,这是可能发生的。因为BroadcastHub是一个异步操作,它将每个元素广播到所有订阅的Sink中,但是无法保证每个Sink都能及时接收到每个元素。这取决于每个Sink的处理速度,以及它们之间的网络延迟等因素。因此,如果您需要确保每个Sink都接收到相同的元素,您可能需要实现自己的同步机制,例如使用分布式锁或消息队列。
原文地址: https://www.cveoy.top/t/topic/lIIy 著作权归作者所有。请勿转载和采集!