Merge branch 'main' into pass-logger-to-confluent

airtai · May 24, 2024 · 09f72ec · 09f72ec
2 parents 93dacfb + 9505fad
commit 09f72ec
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/faststream/__about__.py b/faststream/__about__.py
@@ -1,6 +1,6 @@
 """Simple and fast framework to create message brokers based microservices."""
 
-__version__ = "0.5.8"
+__version__ = "0.5.9"
 
 SERVICE_NAME = f"faststream-{__version__}"
 

diff --git a/faststream/redis/schemas/stream_sub.py b/faststream/redis/schemas/stream_sub.py
@@ -57,4 +57,8 @@ def __init__(
         self.max_records = max_records
 
     def __hash__(self) -> int:
+        if self.group is not None:
+            return hash(
+                f"stream:{self.name} group:{self.group} consumer:{self.consumer}"
+            )
         return hash(f"stream:{self.name}")