correct handle's eventPoll RD_KAFKA_EVENT_DR term

confluentinc · Dec 13, 2021 · 0475aec · 0475aec
1 parent bf3f642
commit 0475aec
Showing 1 changed file with 2 additions and 0 deletions.
diff --git 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
 					}