From 6dc3b763c5898f3ffe647db85b26d6a63fdbac23 Mon Sep 17 00:00:00 2001
From: john <john@johng.cn>
Date: Mon, 30 Jul 2018 10:29:48 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8Dgkafka=E5=AF=B9=E8=B1=A1?=
 =?UTF-8?q?=E5=85=B3=E9=97=AD=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 g/database/gkafka/gkafka.go | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/g/database/gkafka/gkafka.go b/g/database/gkafka/gkafka.go
index 4ff086d20..9c1967641 100644
--- a/g/database/gkafka/gkafka.go
+++ b/g/database/gkafka/gkafka.go
@@ -80,6 +80,9 @@ func NewConfig() *Config {
 
 // Close client.
 func (client *Client) Close() {
+    if client.rawConsumer != nil {
+        client.rawConsumer.Close()
+    }
     if client.consumer != nil {
         client.consumer.Close()
     }