From f8d3089f0676923d40888c06acdb390e8c67c727 Mon Sep 17 00:00:00 2001 From: spataphore1337 Date: Thu, 11 Jul 2024 13:55:56 +0300 Subject: [PATCH] fix: add pattern checking --- faststream/kafka/subscriber/usecase.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/faststream/kafka/subscriber/usecase.py b/faststream/kafka/subscriber/usecase.py index 5b077faf73..e753945538 100644 --- 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,