kafka(ticdc): ddl sink create admin client check error. (#8560)

ref #8523
pingcap · Mar 17, 2023 · 51ba7f3 · 51ba7f3
1 parent 745fe12
commit 51ba7f3
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/cdc/sink/ddlsink/mq/kafka_ddl_sink.go b/cdc/sink/ddlsink/mq/kafka_ddl_sink.go
@@ -55,6 +55,9 @@ func NewKafkaDDLSink(
 	}
 
 	adminClient, err := factory.AdminClient()
+	if err != nil {
+		return nil, cerror.WrapError(cerror.ErrKafkaNewProducer, err)
+	}
 	// 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() {