kafka: bugfix possible nil pointer error on close (#3383)

Signed-off-by: Fabian Martinez <46371672+famarting@users.noreply.github.com>
dapr · Mar 22, 2024 · a9548a7 · a9548a7
1 parent b9c12df
commit a9548a7
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/common/component/kafka/kafka.go b/common/component/kafka/kafka.go
@@ -249,7 +249,9 @@ func (k *Kafka) Close() error {
 		}
 		k.subscribeLock.Unlock()
 
-		errs[1] = k.cg.Close()
+		if k.cg != nil {
+			errs[1] = k.cg.Close()
+		}
 	}
 
 	return errors.Join(errs...)