From 6290709aa895480903bd9bfca53a93a843c23f50 Mon Sep 17 00:00:00 2001 From: hi-rustin Date: Thu, 28 Jul 2022 18:53:50 +0800 Subject: [PATCH] sink(ticdc): warning when using pulsar sink --- cdc/sink/mq/mq.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/cdc/sink/mq/mq.go b/cdc/sink/mq/mq.go index ba6eb69ccea..d99d26295c7 100644 --- 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