diff --git a/src/Hazelcast.Net/DistributedObjects/ReliableTopicMessageExecutor.cs b/src/Hazelcast.Net/DistributedObjects/ReliableTopicMessageExecutor.cs index e1fed0ff3..7ce8bd0fa 100644 --- a/src/Hazelcast.Net/DistributedObjects/ReliableTopicMessageExecutor.cs +++ b/src/Hazelcast.Net/DistributedObjects/ReliableTopicMessageExecutor.cs @@ -213,7 +213,7 @@ private async Task ShouldDisposeAsync(Exception ex) else if (ex.GetType() == typeof(ArgumentOutOfRangeException) && _options.IsLossTolerant) { var old = _sequence; - _sequence = await _ringBuffer.GetTailSequenceAsync().CfAwait() + 1; + _sequence = await _ringBuffer.GetHeadSequenceAsync().CfAwait(); _logger.IfWarning()?.LogWarning("The reliable topic subscription on topic {TopicName} requested a too large sequence {Old}" + ". Jumping from old {Old} sequence to head sequence {Head}.", _ringBuffer.Name, old, old, _sequence);