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()
     }