我使用一个ReliableTopic来重放最后的20000个事件和所有后续事件。
首先,我使用一个ReliableTopic订阅ReliableMessageListener,每次都从retrieveInitialSequence()方法返回0。,对于我正在努力实现的目标,这是正确的吗?
当我订阅ReliableTopic时,我希望以相反的顺序处理其内部RingBuffer中的所有内容,从最新到最老。我可以通过缓冲第一个InternalRingBuffer.size()项,然后逆转这个列表来实现这一点。这取决于能够检索内部RingBuffer的大小,因为它可能不是满的。但是,当我在一个新连接的实例上调用InternalRingBuffer.size()时,尽管缓冲区中有项,它还是返回了0。这是为什么,以及我如何修复它?
发布于 2019-02-08 15:02:53
您发现了一个bug,我创建了以下问题:https://github.com/hazelcast/hazelcast/issues/14468
https://stackoverflow.com/questions/54189547
复制相似问题