Merge pull request #833 from Aiven-Open/matyaskuti/fix_rest_proxy_com…

…mit_empty_payload Fix no-payload commit in consumer
Aiven-Open · Mar 5, 2024 · af21074 · af21074
2 parents 4ae29e6 + c8f3923
commit af21074
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/karapace/kafka/consumer.py b/karapace/kafka/consumer.py
@@ -86,7 +86,10 @@ def commit(  # type: ignore[override]
             if message is not None:
                 return super().commit(message=message, asynchronous=False)
 
-            return super().commit(offsets=offsets, asynchronous=False)
+            if offsets is not None:
+                return super().commit(offsets=offsets, asynchronous=False)
+
+            return super().commit(asynchronous=False)
         except KafkaException as exc:
             raise_from_kafkaexception(exc)