diff --git a/src/KafkaNET.Library/Consumers/FetcherRunnable.cs b/src/KafkaNET.Library/Consumers/FetcherRunnable.cs
index 5c0385b..24960ec 100644
--- a/src/KafkaNET.Library/Consumers/FetcherRunnable.cs
+++ b/src/KafkaNET.Library/Consumers/FetcherRunnable.cs
@@ -106,7 +106,11 @@ namespace Kafka.Client.Consumers
                             switch (messages.ErrorCode)
                             {
                                 case (short)ErrorMapping.NoError:
-                                    partitionTopicInfo.ConsumedOffsetOutOfRange = false;
+                                    if (partitionTopicInfo.ConsumedOffsetOutOfRange)
+                                    {
+                                        partitionTopicInfo.ConsumedOffsetOutOfRange = false;
+                                    }
+
                                     int bytesRead = partitionTopicInfo.Add(messages);
                                     // TODO: The highwater offset on the message set is the end of the log partition. If the message retrieved is -1 of that offset, we are at the end.
                                     if (messages.Messages.Any())