fix(patch): [sc-13174] use eof offset without increment (#40)

ordo-one · Aug 29, 2024 · b2e3d1f · b2e3d1f
1 parent 81ae1f9
commit b2e3d1f
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/Sources/Kafka/RDKafka/RDKafkaClient.swift b/Sources/Kafka/RDKafka/RDKafkaClient.swift
@@ -675,7 +675,7 @@ public final class RDKafkaClient: Sendable {
         changesList.setOffset(
             topic: message.topic,
             partition: message.partition,
-            offset: .init(rawValue: message.offset.rawValue + 1)
+            offset: message.eof ? message.offset : .init(rawValue: message.offset.rawValue + 1)
         )
 
         let error = changesList.withListPointer { listPointer in
@@ -714,7 +714,7 @@ public final class RDKafkaClient: Sendable {
             changesList.setOffset(
                 topic: message.topic,
                 partition: message.partition,
-                offset: .init(rawValue: message.offset.rawValue + 1)
+                offset: message.eof ? message.offset : .init(rawValue: message.offset.rawValue + 1)
             )
 
             // Unretained pass because the reference that librdkafka holds to capturedClosure