我使用的是ReliableTopic重播最后一个20000个事件和所有后续事件。
首先,这是我用ReliableTopic
订阅ReliableMessageListener
,我从0
方法每次返回retrieveInitialSequence()
。这是正确的什么我想达到什么目的?
当我订阅ReliableTopic
,我想处理一切,是在以相反的顺序其内部RingBuffer
,从最新到最旧。我可以缓冲第一InternalRingBuffer.size()
项目,然后扭转这一列表实现这一目标。这依赖于能够获取内部RingBuffer
的大小,因为它可能不完整。然而,当我打电话InternalRingBuffer.size()
上新连接的情况下,尽管在缓冲区中有是项目,它返回0
。这是为什么?如何解决?
你已经发现了一个错误,我已经创建了以下问题:https://github.com/hazelcast/hazelcast/issues/14468