Fix error test when ignoring RD_KAFKA_RESP_ERR_NO_ERROR in storeMessageOffset (#141)

gmilos · web-flow · commit 73bc4b43bb27 · 2023-11-01T14:08:32.000Z
diff --git a/Sources/Kafka/RDKafka/RDKafkaClient.swift b/Sources/Kafka/RDKafka/RDKafkaClient.swift
@@ -525,7 +525,7 @@ final class RDKafkaClient: Sendable {
             // which can occur during rebalancing or when the consumer is shutting down.
             // See "Upgrade considerations" for more details: https://github.com/confluentinc/librdkafka/releases/tag/v1.9.0
             // Since Kafka Consumers are designed for at-least-once processing, failing to commit here is acceptable.
-            if error != RD_KAFKA_RESP_ERR__STATE {
+            if error == RD_KAFKA_RESP_ERR__STATE {
                 return
             }
             throw KafkaError.rdKafkaError(wrapping: error)

Original file line number	Diff line number	Diff line change
`@@ -525,7 +525,7 @@ final class RDKafkaClient: Sendable {`
`525`	`525`	`// which can occur during rebalancing or when the consumer is shutting down.`
`526`	`526`	`// See "Upgrade considerations" for more details: https://github.com/confluentinc/librdkafka/releases/tag/v1.9.0`
`527`	`527`	`// Since Kafka Consumers are designed for at-least-once processing, failing to commit here is acceptable.`
`528`		`- if error != RD_KAFKA_RESP_ERR__STATE {`
	`528`	`+ if error == RD_KAFKA_RESP_ERR__STATE {`
`529`	`529`	`return`
`530`	`530`	`}`
`531`	`531`	`throw KafkaError.rdKafkaError(wrapping: error)`