From 83f4f792cafaa0ae6a8e3935871ce5b827a646a7 Mon Sep 17 00:00:00 2001
From: Marcos Schroh <marcos.schroh@kpn.com>
Date: Thu, 11 Aug 2022 13:30:27 +0200
Subject: [PATCH] fix: remove unsubscribe before stopping consumer

---
 kstreams/streams.py | 1 -
 1 file changed, 1 deletion(-)

diff --git a/kstreams/streams.py b/kstreams/streams.py
index 9ae879f0..fb7a5001 100644
--- 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