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 <github@bernd.dev>
dapr · Aug 11, 2023 · d16fd9a · d16fd9a
1 parent ecf14bc
commit d16fd9a
Showing 1 changed file with 2 additions and 0 deletions.
diff --git 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