fix: properly handle produce operation failure

infinyon · Jul 20, 2023 · 26dab10 · 26dab10
1 parent 146e334
commit 26dab10
Showing 1 changed file with 0 additions and 5 deletions.
diff --git a/crates/fluvio/src/producer/partition_producer.rs b/crates/fluvio/src/producer/partition_producer.rs
@@ -280,11 +280,6 @@ impl PartitionProducer {
                 let mut futures = Vec::with_capacity(partition_count);
                 for topic in produce_response.responses.into_iter() {
                     for partition in topic.partitions {
-                        if partition.error_code.is_error() {
-                            return Err(FluvioError::from(ProducerError::from(
-                                partition.error_code,
-                            )));
-                        }
                         futures.push(ProducePartitionResponseFuture::ready(
                             partition.base_offset,
                             partition.error_code,