From 0475aec77e0f73a75f2f7fe18e1c7b674e63036d Mon Sep 17 00:00:00 2001
From: Jiajia Zhong <zhong2plus@gmail.com>
Date: Thu, 15 Jul 2021 20:44:02 +0800
Subject: [PATCH] correct handle's eventPoll RD_KAFKA_EVENT_DR term

---
 kafka/event.go | 2 ++
 1 file changed, 2 insertions(+)

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
 					}