diff --git a/src/osm_common/msgkafka.py b/src/osm_common/msgkafka.py
index 02b8241..516251c 100644
--- a/src/osm_common/msgkafka.py
+++ b/src/osm_common/msgkafka.py
@@ -121,7 +121,7 @@
         aiocallback=None,
         group_id=None,
         from_beginning=None,
-        **kwargs
+        **kwargs,
     ):
         """
         Asyncio read from one or several topics.
@@ -159,14 +159,14 @@
                         message.topic,
                         yaml.safe_load(message.key),
                         yaml.safe_load(message.value),
-                        **kwargs
+                        **kwargs,
                     )
                 elif aiocallback:
                     await aiocallback(
                         message.topic,
                         yaml.safe_load(message.key),
                         yaml.safe_load(message.value),
-                        **kwargs
+                        **kwargs,
                     )
                 else:
                     return (