diff --git a/pkg/exporter/channel_registry.go b/pkg/exporter/channel_registry.go index 39db655a..4f5ff0e4 100644 --- a/pkg/exporter/channel_registry.go +++ b/pkg/exporter/channel_registry.go @@ -59,7 +59,7 @@ func (r *ChannelBasedReceiverRegistry) Register(name string, receiver sinks.Sink err := receiver.Send(context.Background(), &ev) if err != nil { r.MetricsStore.SendErrors.Inc() - log.Debug().Err(err).Str("sink", name).Str("event", ev.Message).Msg("Cannot send event") + log.Warn().Err(err).Str("sink", name).Str("event", ev.Message).Msg("Cannot send event") } case <-exitCh: log.Info().Str("sink", name).Msg("Closing the sink") diff --git a/pkg/exporter/sync_registry.go b/pkg/exporter/sync_registry.go index 8c6294ec..c7abd4d3 100644 --- a/pkg/exporter/sync_registry.go +++ b/pkg/exporter/sync_registry.go @@ -16,7 +16,7 @@ type SyncRegistry struct { func (s *SyncRegistry) SendEvent(name string, event *kube.EnhancedEvent) { err := s.reg[name].Send(context.Background(), event) if err != nil { - log.Debug().Err(err).Str("sink", name).Str("event", string(event.UID)).Msg("Cannot send event") + log.Warn().Err(err).Str("sink", name).Str("event", string(event.UID)).Msg("Cannot send event") } }