diff --git a/karapace/kafka/consumer.py b/karapace/kafka/consumer.py index 2899820cd..762295d3d 100644 --- 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)