Pārlūkot izejas kodu

Merge pull request #24 from Shopify/fix_consumer_nilpointers

Fix nil-pointer panic in consumer.
Evan Huus 12 gadi atpakaļ
vecāks
revīzija
f124a9edd7
1 mainītis faili ar 1 papildinājumiem un 0 dzēšanām
  1. 1 0
      consumer.go

+ 1 - 0
consumer.go

@@ -156,6 +156,7 @@ func (c *Consumer) fetchMessages() {
 					return
 					return
 				}
 				}
 			}
 			}
+			continue
 		}
 		}
 
 
 		block := response.GetBlock(c.topic, c.partition)
 		block := response.GetBlock(c.topic, c.partition)