diff --git a/consumergroup/consumer_group.go b/consumergroup/consumer_group.go
index 76d7ddf..b602ee8 100644
--- a/consumergroup/consumer_group.go
+++ b/consumergroup/consumer_group.go
@@ -421,7 +421,9 @@ partitionConsumerLoop:
 					break partitionConsumerLoop
 
 				case messages <- message:
-					lastOffset = message.Offset
+					if message != nil {
+						lastOffset = message.Offset
+					}
 					continue partitionConsumerLoop
 				}
 			}