diff --git a/kafka/event.go b/kafka/event.go
index d7f0b6189..6357ad858 100644
--- a/kafka/event.go
+++ b/kafka/event.go
@@ -251,6 +251,8 @@ out:
 					select {
 					case *ch <- msg:
 					case <-termChan:
+						retval = nil
+						term = true
 						break out
 					}