Protect against nil messages, which happen very infrequently.

The root cause of nil messages has not been diagnosed. Run "go fmt"
wvanbergen · Dec 1, 2015 · 2027a51 · 2027a51
1 parent 1a8639a
commit 2027a51
Showing 1 changed file with 3 additions and 1 deletion.
diff --git 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
 				}
 			}