fix(patch): [sc-4740] add additional failure as success #13

ordo-one · Nov 7, 2023 · de7534a · de7534a
1 parent 38b6121
commit de7534a
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/Sources/Kafka/RDKafka/RDKafkaClient.swift b/Sources/Kafka/RDKafka/RDKafkaClient.swift
@@ -893,6 +893,10 @@ final class RDKafkaClient: Sendable {
             }
             defer { rd_kafka_error_destroy(error) }
 
+            if rd_kafka_error_code(error) == RD_KAFKA_RESP_ERR__STATE { // No active transaction
+                return
+            }
+
             /* check if transaction abort is retriable */
             if rd_kafka_error_is_retriable(error) == 1 {
                 continue