fix: add pattern checking

airtai · Jul 11, 2024 · f8d3089 · f8d3089
1 parent 6534e00
commit f8d3089
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/faststream/kafka/subscriber/usecase.py b/faststream/kafka/subscriber/usecase.py
@@ -149,7 +149,7 @@ async def start(self) -> None:
             **self.__connection_args,
         )
 
-        if self.topics:
+        if self.topics or self.__pattern:
             consumer.subscribe(
                 topics=self.topics,
                 pattern=self.__pattern,