sink(ticdc): warning when using pulsar sink

pingcap · Jul 28, 2022 · 6290709 · 6290709
1 parent 0e358fd
commit 6290709
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/cdc/sink/mq/mq.go b/cdc/sink/mq/mq.go
@@ -474,6 +474,9 @@ func NewKafkaSaramaSink(ctx context.Context, sinkURI *url.URL,
 func NewPulsarSink(ctx context.Context, sinkURI *url.URL,
 	replicaConfig *config.ReplicaConfig, errCh chan error,
 ) (*mqSink, error) {
+	log.Warn("Pulsar Sink is about to go out of maintenance, " +
+		"it has not been production tested, and there is no support for new features. " +
+		"Please try not to use it, it will stop being supported in the new version.")
 	s := sinkURI.Query().Get(config.ProtocolKey)
 	if s != "" {
 		replicaConfig.Sink.Protocol = s