From 0ff71b815d6caee78ee6810cfe0847f8a9361326 Mon Sep 17 00:00:00 2001 From: Sayan Hazra Date: Tue, 23 Jul 2019 14:19:33 +0200 Subject: [PATCH 1/2] Disable logging headers in NATS dispatcher --- contrib/natss/pkg/dispatcher/dispatcher.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/contrib/natss/pkg/dispatcher/dispatcher.go b/contrib/natss/pkg/dispatcher/dispatcher.go index d0655050f10..c22f219b8ed 100644 --- a/contrib/natss/pkg/dispatcher/dispatcher.go +++ b/contrib/natss/pkg/dispatcher/dispatcher.go @@ -126,7 +126,7 @@ func createReceiverFunction(s *SubscriptionsSupervisor, logger *zap.SugaredLogge } return err } - logger.Infof("Published [%s] : '%s'", channel.String(), m.Headers) + logger.Debugf("Published [%s] : '%s'", channel.String(), m.Headers) return nil } } From 2ba493583cbe7097dc6a44059775d9c964875bf1 Mon Sep 17 00:00:00 2001 From: Sayan Hazra Date: Tue, 23 Jul 2019 17:07:51 +0200 Subject: [PATCH 2/2] Changed log level to debug --- contrib/natss/pkg/dispatcher/dispatcher.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/contrib/natss/pkg/dispatcher/dispatcher.go b/contrib/natss/pkg/dispatcher/dispatcher.go index c22f219b8ed..53a5cd7b05d 100644 --- a/contrib/natss/pkg/dispatcher/dispatcher.go +++ b/contrib/natss/pkg/dispatcher/dispatcher.go @@ -270,7 +270,7 @@ func (s *SubscriptionsSupervisor) subscribe(channel provisioners.ChannelReferenc s.logger.Error("Failed to unmarshal message: ", zap.Error(err)) return } - s.logger.Sugar().Infof("NATSS message received from subject: %v; sequence: %v; timestamp: %v, headers: '%s'", msg.Subject, msg.Sequence, msg.Timestamp, message.Headers) + s.logger.Sugar().Debugf("NATSS message received from subject: %v; sequence: %v; timestamp: %v, headers: '%s'", msg.Subject, msg.Sequence, msg.Timestamp, message.Headers) if err := s.dispatcher.DispatchMessage(&message, subscription.SubscriberURI, subscription.ReplyURI, provisioners.DispatchDefaults{Namespace: channel.Namespace}); err != nil { s.logger.Error("Failed to dispatch message: ", zap.Error(err)) return