From d16fd9ac6342c8743ff4b8a20a4ef5ba51c6b24f Mon Sep 17 00:00:00 2001 From: "Alessandro (Ale) Segala" <43508+ItalyPaleAle@users.noreply.github.com> Date: Thu, 10 Aug 2023 17:27:58 -0700 Subject: [PATCH] Add deprecation warning to NATS Streaming component (#3043) Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com> Co-authored-by: Mukundan Sundararajan <65565396+mukundansundar@users.noreply.github.com> Co-authored-by: Bernd Verst --- pubsub/natsstreaming/natsstreaming.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/pubsub/natsstreaming/natsstreaming.go b/pubsub/natsstreaming/natsstreaming.go index 51817ac72..5628f1fb5 100644 --- a/pubsub/natsstreaming/natsstreaming.go +++ b/pubsub/natsstreaming/natsstreaming.go @@ -179,6 +179,8 @@ func parseNATSStreamingMetadata(meta pubsub.Metadata) (natsMetadata, error) { } func (n *natsStreamingPubSub) Init(_ context.Context, metadata pubsub.Metadata) error { + n.logger.Warn("⚠️ The NATS Streaming PubSub component is deprecated due to the deprecation of NATS Server, and will be removed from Dapr 1.13") + m, err := parseNATSStreamingMetadata(metadata) if err != nil { return err