diff --git a/kafka/consumer/fetcher.py b/kafka/consumer/fetcher.py
index ad703a594..cf0b49563 100644
--- a/kafka/consumer/fetcher.py
+++ b/kafka/consumer/fetcher.py
@@ -359,7 +359,7 @@ def _append(self, drained, part, max_records):
                 part_records = part.take(max_records)
                 if not part_records:
                     return 0
-                next_offset = part_records[-1].offset + 1
+                next_offset = part.fetch_offset
 
                 log.log(0, "Returning fetched records at offset %d for assigned"
                            " partition %s and update position to %s", position,