From 20b01ba95a6d684c9d8547e39452dec354459aa4 Mon Sep 17 00:00:00 2001 From: Frank Hamand Date: Mon, 12 Aug 2024 20:35:35 +0100 Subject: [PATCH] cargo fmt --- src/sinks/kafka/service.rs | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) diff --git a/src/sinks/kafka/service.rs b/src/sinks/kafka/service.rs index e1f69ce7e51ce..087795864b594 100644 --- a/src/sinks/kafka/service.rs +++ b/src/sinks/kafka/service.rs @@ -174,15 +174,15 @@ impl Service 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),