🔖 Release version 0.1.1 (#18)

* 🔥 Remove `loop` argument

* 🔖 Release version `0.1.1`

Author: gabrielmbmb

kaflow/__init__.py

@@ -35,4 +35,4 @@
 
     __all__.append("Protobuf")
 
-__version__ = "0.1.0"
+__version__ = "0.1.1"

kaflow/applications.py

@@ -276,7 +276,6 @@ def _add_topic_consumer_func(
     def _create_consumer(self) -> AIOKafkaConsumer:
         return AIOKafkaConsumer(
             *self._consumers.keys(),
-            loop=self._loop,
             bootstrap_servers=self.brokers,
             client_id=self.client_id,
             group_id=self.group_id,
@@ -314,7 +313,6 @@ def _create_consumer(self) -> AIOKafkaConsumer:
 
     def _create_producer(self) -> AIOKafkaProducer:
         return AIOKafkaProducer(
-            loop=self._loop,
             bootstrap_servers=self.brokers,
             client_id=self.client_id,
             metadata_max_age_ms=self.metadata_max_age_ms,