address comment

pingcap · Feb 1, 2023 · 2afd9d7 · 2afd9d7
1 parent 428ddce
commit 2afd9d7
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pkg/sink/kafka/v2/kafka-go-client.go b/pkg/sink/kafka/v2/kafka-go-client.go
@@ -59,6 +59,9 @@ func NewKafkaGoClient(ctx context.Context, options *pkafka.Options) (pkafka.Clie
 		return nil, errors.Trace(err)
 	}
 	tlsConfig, err := completeSSLConfig(options)
+	if err != nil {
+		return nil, errors.Trace(err)
+	}
 	transport := &kafka.Transport{
 		SASL:        mechanism,
 		ClientID:    clientID,