fix panic.

pingcap · Mar 14, 2023 · 41e9f01 · 41e9f01
1 parent 446686c
commit 41e9f01
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/cdc/sink/dmlsink/mq/kafka_dml_sink.go b/cdc/sink/dmlsink/mq/kafka_dml_sink.go
@@ -62,7 +62,7 @@ func NewKafkaDMLSink(
 	// We must close adminClient when this func return cause by an error
 	// otherwise the adminClient will never be closed and lead to a goroutine leak.
 	defer func() {
-		if err != nil {
+		if err != nil && adminClient != nil {
 			adminClient.Close()
 		}
 	}()
@@ -86,7 +86,7 @@ func NewKafkaDMLSink(
 	// Preventing leaks when error occurs.
 	// This also closes the client in p.Close().
 	defer func() {
-		if err != nil {
+		if err != nil && p != nil {
 			p.Close()
 		}
 	}()