remove unnecessary schema check when create sarama sink.

pingcap · Oct 29, 2021 · dc3e683 · dc3e683
1 parent 3390157
commit dc3e683
Showing 1 changed file with 0 additions and 5 deletions.
diff --git a/cdc/sink/mq.go b/cdc/sink/mq.go
@@ -398,11 +398,6 @@ func (k *mqSink) writeToProducer(ctx context.Context, message *codec.MQMessage,
 }
 
 func newKafkaSaramaSink(ctx context.Context, sinkURI *url.URL, filter *filter.Filter, replicaConfig *config.ReplicaConfig, opts map[string]string, errCh chan error) (*mqSink, error) {
-	scheme := strings.ToLower(sinkURI.Scheme)
-	if scheme != "kafka" && scheme != "kafka+ssl" {
-		return nil, cerror.ErrKafkaInvalidConfig.GenWithStack("can't create MQ sink with unsupported scheme: %s", scheme)
-	}
-
 	config := kafka.NewConfig()
 	if err := config.Initialize(sinkURI, replicaConfig, opts); err != nil {
 		return nil, cerror.WrapError(cerror.ErrKafkaInvalidConfig, err)