diff --git a/src/sinks/kafka/service.rs b/src/sinks/kafka/service.rs index c509dfec70fb5..e1f69ce7e51ce 100644 --- a/src/sinks/kafka/service.rs +++ b/src/sinks/kafka/service.rs @@ -171,7 +171,7 @@ impl Service for KafkaService { record = original_record; tokio::time::sleep(Duration::from_millis(100)).await; } - // A final/unretriable error occurred. + // A final/non-retriable error occurred. Err(( err @ KafkaError::MessageProduction( RDKafkaErrorCode::InvalidMessage |