We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 6b3bda0 commit c8c1c58Copy full SHA for c8c1c58
src/sinks/elasticsearch/config.rs
@@ -443,7 +443,9 @@ impl DataStreamConfig {
443
let (dtype, dataset, namespace) = if !self.auto_routing {
444
(self.dtype(log)?, self.dataset(log)?, self.namespace(log)?)
445
} else {
446
- let data_stream = log.get(event_path!("data_stream")).and_then(|ds| ds.as_object());
+ let data_stream = log
447
+ .get(event_path!("data_stream"))
448
+ .and_then(|ds| ds.as_object());
449
let dtype = data_stream
450
.and_then(|ds| ds.get("type"))
451
.map(|value| value.to_string_lossy().into_owned())
0 commit comments