diff --git a/src/sources/syslog.rs b/src/sources/syslog.rs index acd705daff33c..3991d39ef5fd3 100644 --- a/src/sources/syslog.rs +++ b/src/sources/syslog.rs @@ -236,7 +236,7 @@ impl SourceConfig for SyslogConfig { Deserializer::Syslog( SyslogDeserializerConfig::from_source(SyslogConfig::NAME).build(), ), - ); + ).with_log_namespace(log_namespace); build_unix_stream_source( path, @@ -293,7 +293,7 @@ impl TcpSource for SyslogTcpSource { Decoder::new( Framer::OctetCounting(OctetCountingDecoder::new_with_max_length(self.max_length)), Deserializer::Syslog(SyslogDeserializerConfig::from_source(SyslogConfig::NAME).build()), - ) + ).with_log_namespace(self.log_namespace) } fn handle_events(&self, events: &mut [Event], host: SocketAddr) { @@ -347,7 +347,7 @@ pub fn udp( Deserializer::Syslog( SyslogDeserializerConfig::from_source(SyslogConfig::NAME).build(), ), - ), + ).with_log_namespace(log_namespace), ) .take_until(shutdown) .filter_map(|frame| {