Actually allow log namespacing when using the syslog source.

vectordotdev · Dec 21, 2024 · e7194ff · e7194ff
1 parent 029a2ff
commit e7194ff
Showing 1 changed file with 3 additions and 3 deletions.
diff --git 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| {