diff --git a/redis_canal/agent.py b/redis_canal/agent.py
index dead635..07b4e3d 100644
--- a/redis_canal/agent.py
+++ b/redis_canal/agent.py
@@ -175,8 +175,8 @@ async def _get_redis_stream_keys(self) -> list[str]:
                 await self.redis_client.xinfo_stream(self.redis_stream_key)
             except redis.ResponseError:
                 logger.error(f"{self.redis_stream_key} is not a stream or does not exist")
-                raise
-            keys.append(self.redis_stream_key)
+            else:
+                keys.append(self.redis_stream_key)
 
         if self.redis_stream_key_prefix:
             if self.redis_stream_key_prefix == "*":