From e0480ea11bfb4a0ded3768b6511f9d45b094233b Mon Sep 17 00:00:00 2001 From: Bohan Zhang Date: Thu, 31 Aug 2023 22:19:23 +0800 Subject: [PATCH] fix: use match to handle non queue full error instead of assert (#11998) --- src/connector/src/sink/kafka.rs | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/src/connector/src/sink/kafka.rs b/src/connector/src/sink/kafka.rs index f52eb0bfa36f8..046e78cef9d54 100644 --- a/src/connector/src/sink/kafka.rs +++ b/src/connector/src/sink/kafka.rs @@ -430,10 +430,13 @@ impl KafkaSinkWriter { Err((e, rec)) => { err = e; record = rec; - // FIXME: Will there possibly exist other errors? - assert!(err == KafkaError::MessageProduction(RDKafkaErrorCode::QueueFull)); - tokio::time::sleep(self.config.retry_interval).await; - continue; + match err { + KafkaError::MessageProduction(RDKafkaErrorCode::QueueFull) => { + tokio::time::sleep(self.config.retry_interval).await; + continue; + } + _ => break, + } } } }