fix: remove unsubscribe before stopping consumer (#40)

Co-authored-by: Marcos Schroh <[email protected]>
kpn · Aug 11, 2022 · 418210f · 418210f
1 parent 11e8288
commit 418210f
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/kstreams/streams.py b/kstreams/streams.py
@@ -49,7 +49,6 @@ async def stop(self) -> None:
         if not self.running:
             return None
 
-        self.consumer.unsubscribe()
         await self.consumer.stop()
         self.running = False