🔖 Release version 0.1.1 (#18)

* 🔥 Remove `loop` argument * 🔖 Release version `0.1.1`
gabrielmbmb · Apr 10, 2023 · 790eb4a · 790eb4a
1 parent aa0bf34
commit 790eb4a
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 3 deletions.
diff --git a/kaflow/__init__.py b/kaflow/__init__.py
@@ -35,4 +35,4 @@
 
     __all__.append("Protobuf")
 
-__version__ = "0.1.0"
+__version__ = "0.1.1"
diff --git a/kaflow/applications.py b/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,
Original file line number	Diff line number	Diff line change
Expand Up		@@ -35,4 +35,4 @@

		__all__.append("Protobuf")

		__version__ = "0.1.0"
		__version__ = "0.1.1"