Update src/sinks/kafka/service.rs

Co-authored-by: Bruce Guenter <bruce.guenter@datadoghq.com>
vectordotdev · Sep 22, 2023 · 8bacaf5 · 8bacaf5
1 parent 134fb9b
commit 8bacaf5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/sinks/kafka/service.rs b/src/sinks/kafka/service.rs
@@ -105,7 +105,7 @@ impl Service<KafkaRequest> for KafkaService {
             match this.kafka_producer.send(record, Timeout::Never).await {
                 Ok((_partition, _offset)) => {
                     let raw_byte_size =
-                        request.body.len() + request.metadata.key.map(|x| x.len()).unwrap_or(0);
+                        request.body.len() + request.metadata.key.map_or(0, |x| x.len());
                     Ok(KafkaResponse {
                         event_byte_size,
                         raw_byte_size,