diff --git a/src/Kafka/Consumer/Process.php b/src/Kafka/Consumer/Process.php
index <HASH>..<HASH> 100644
--- a/src/Kafka/Consumer/Process.php
+++ b/src/Kafka/Consumer/Process.php
@@ -554,7 +554,7 @@ class Process
                     break 2;
                 }
 
-                $offsets[$topic['topicName']][$part['partition']] = $part['offset'];
+                $offsets[$topic['topicName']][$part['partition']] = $part['offset'] - 1;
             }
         }
         $assign->setFetchOffsets($offsets);
fix lost one message when consumer restart

when consumer restart will lost first message in partisions

i have send 5 messages ,but get only get 4 message

my kafka version is <I>