修复gkafka对象关闭问题

2026-06-07 10:22:11 +08:00 · 2018-07-30 10:29:48 +08:00
parent aadbb774f8
commit 6dc3b763c5
1 changed files with 3 additions and 0 deletions
--- 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()
    }