cargo fmt

vectordotdev · Aug 12, 2024 · 20b01ba · 20b01ba
1 parent 5cc3f93
commit 20b01ba
Showing 1 changed file with 9 additions and 9 deletions.
diff --git a/src/sinks/kafka/service.rs b/src/sinks/kafka/service.rs
@@ -174,15 +174,15 @@ impl Service<KafkaRequest> for KafkaService {
                     // A final/non-retriable error occurred.
                     Err((
                         err @ KafkaError::MessageProduction(
-                            RDKafkaErrorCode::InvalidMessage |
-                            RDKafkaErrorCode::InvalidMessageSize |
-                            RDKafkaErrorCode::MessageSizeTooLarge |
-                            RDKafkaErrorCode::UnknownTopicOrPartition |
-                            RDKafkaErrorCode::InvalidRecord |
-                            RDKafkaErrorCode::InvalidRequiredAcks |
-                            RDKafkaErrorCode::TopicAuthorizationFailed |
-                            RDKafkaErrorCode::UnsupportedForMessageFormat |
-                            RDKafkaErrorCode::ClusterAuthorizationFailed
+                            RDKafkaErrorCode::InvalidMessage
+                            | RDKafkaErrorCode::InvalidMessageSize
+                            | RDKafkaErrorCode::MessageSizeTooLarge
+                            | RDKafkaErrorCode::UnknownTopicOrPartition
+                            | RDKafkaErrorCode::InvalidRecord
+                            | RDKafkaErrorCode::InvalidRequiredAcks
+                            | RDKafkaErrorCode::TopicAuthorizationFailed
+                            | RDKafkaErrorCode::UnsupportedForMessageFormat
+                            | RDKafkaErrorCode::ClusterAuthorizationFailed,
                         ),
                         _,
                     )) => return Err(err),