fix: unsubscribe consumer before stopping (#37)

Co-authored-by: Marcos Schroh <[email protected]>
kpn · Aug 10, 2022 · b5c3b0b · b5c3b0b
1 parent d3902e3
commit b5c3b0b
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/kstreams/streams.py b/kstreams/streams.py
@@ -48,6 +48,8 @@ def _create_consumer(self) -> ConsumerType:
     async def stop(self) -> None:
         if not self.running:
             return None
+
+        self.consumer.unsubscribe()
         await self.consumer.stop()
         self.running = False