Skip clean subscriptions when parsing responses

aaronkavlie-wf · Aug 17, 2015 · fa444e4 · fa444e4
1 parent 8ec44fb
commit fa444e4
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/offset_manager.go b/offset_manager.go
@@ -396,6 +396,10 @@ func (bom *brokerOffsetManager) flushToBroker() {
 	}
 
 	for s := range bom.subscriptions {
+		if request.blocks[s.topic] == nil || request.blocks[s.topic][s.partition] == nil {
+			continue
+		}
+
 		var err KError
 		var ok bool