Akka BroadcastHub 陷阱:元素少于缓冲区大小导致消息丢失
是的,我知道。当使用 'BroadcastHub' 时,如果 source 的元素个数小于 buffer size,则下游可能会收不到任何消息。这是因为 'BroadcastHub' 只有在缓冲区填满时才会开始发送消息,而在这种情况下,缓冲区不会被填满。要解决这个问题,可以使用 'MergeHub' 来代替 'BroadcastHub',以确保下游始终可以接收到消息。
原文地址: https://www.cveoy.top/t/topic/lIIx 著作权归作者所有。请勿转载和采集!