From 054fd2e7d8c788c0e782bdc5ee780eb78d299589 Mon Sep 17 00:00:00 2001
From: "Nathan.fooo" <86001920+appflowy@users.noreply.github.com>
Date: Mon, 16 Sep 2024 15:31:05 +0800
Subject: [PATCH] chore: ignore create redis stream error when create a new
 group (#826)

---
 libs/collab-stream/src/client.rs | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/libs/collab-stream/src/client.rs b/libs/collab-stream/src/client.rs
index ce976146..57d17fd1 100644
--- a/libs/collab-stream/src/client.rs
+++ b/libs/collab-stream/src/client.rs
@@ -3,6 +3,7 @@ use crate::pubsub::{CollabStreamPub, CollabStreamSub};
 use crate::stream::CollabStream;
 use crate::stream_group::{StreamConfig, StreamGroup};
 use redis::aio::ConnectionManager;
+use tracing::error;
 
 pub const CONTROL_STREAM_KEY: &str = "af_collab_control";
 
@@ -36,7 +37,12 @@ impl CollabRedisStream {
       self.connection_manager.clone(),
       StreamConfig::new().with_max_len(1000),
     );
-    group.ensure_consumer_group().await?;
+
+    // don't return error when create consumer group failed
+    if let Err(err) = group.ensure_consumer_group().await {
+      error!("Failed to ensure consumer group: {}", err);
+    }
+
     Ok(group)
   }