diff --git a/core/Processors/Internal/StoreChangelogReader.cs b/core/Processors/Internal/StoreChangelogReader.cs
index 499c68b9..794dd050 100644
--- a/core/Processors/Internal/StoreChangelogReader.cs
+++ b/core/Processors/Internal/StoreChangelogReader.cs
@@ -266,7 +266,7 @@ internal bool HasRestoredToEnd(ChangelogMetadata changelogMetadata)
            
             if(changelogMetadata.CurrentOffset >= endOffset 
                // changelog topic has a delete policy, begin offset > end offset because the topic is empty #195
-               || changelogMetadata.BeginOffset > changelogMetadata.RestoreEndOffset)
+               || changelogMetadata.BeginOffset >= changelogMetadata.RestoreEndOffset)
                 return true;
             
             if (!changelogMetadata.BufferedRecords.Any())