Added manual commit to actual code

src/hexkit/providers/akafka/provider.py

@@ -335,6 +335,10 @@ def __init__(  # noqa: PLR0913
         """
         ...
 
+    async def commit(self, offsets=None):
+        """Commit offsets to Kafka Broker."""
+        ...
+
     async def start(self) -> None:
         """Setup the consumer."""
         ...
@@ -475,3 +479,4 @@ async def run(self, forever: bool = True) -> None:
         else:
             event = await self._consumer.__anext__()
             await self._consume_event(event)
+        await self._consumer.commit()

tests/integration/test_akafka.py

@@ -203,10 +203,9 @@ async def test_consumer_commit_mode(kafka_fixture: KafkaFixture):  # noqa: F811
         consumer = cast(AIOKafkaConsumer, event_subscriber._consumer)
 
         # check that the consumer is in manual commit mode
-        assert await consumer.committed(partition=partition) == None
+        assert not consumer._enable_auto_commit
 
-        # commit and check if the event reached the correct partition
-        await consumer.commit()
+        # check if the event was committed successfully
         consumer_offset = await consumer.committed(partition=partition)
         assert consumer_offset == 1