diff --git a/src/Consumer/Process.php b/src/Consumer/Process.php
index 00061fa5..254ae0b7 100644
--- a/src/Consumer/Process.php
+++ b/src/Consumer/Process.php
@@ -651,7 +651,7 @@ public function succFetch(array $result, int $fd): void
                 foreach ($part['messages'] as $message) {
                     $this->messages[$topic['topicName']][$part['partition']][] = $message;
 
-                    $offset = $message['offset'];
+                    $offset = $offset > $message['offset'] ? $offset + 1 : $message['offset'];
                 }
 
                 $consumerOffset = ($part['highwaterMarkOffset'] > $offset) ? ($offset + 1) : $offset;