From 27e874ed1eda67271ae8ca87ccc02be49dc399e8 Mon Sep 17 00:00:00 2001
From: "review512jwy@163.com" <“review512jwy@163.com”>
Date: Sun, 12 Jul 2026 10:57:29 +0800
Subject: [PATCH] =?UTF-8?q?=E5=AE=8C=E5=96=84group=E5=AD=98=E5=9C=A8?=
 =?UTF-8?q?=E5=88=A4=E5=AE=9A?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../datacenter/receiver/listener/RedisStreamConsumer.java   | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/src/main/java/com/techsor/datacenter/receiver/listener/RedisStreamConsumer.java b/src/main/java/com/techsor/datacenter/receiver/listener/RedisStreamConsumer.java
index 79f3c20..c447477 100644
--- a/src/main/java/com/techsor/datacenter/receiver/listener/RedisStreamConsumer.java
+++ b/src/main/java/com/techsor/datacenter/receiver/listener/RedisStreamConsumer.java
@@ -160,7 +160,11 @@ public class RedisStreamConsumer {
                     .createGroup(stream, ReadOffset.from("0-0"), GROUP);
             log.info("create group success stream={}", stream);
         } catch (Exception e) {
-            log.info("group exists stream={}", stream);
+            if (e.getMessage() != null && e.getCause().getMessage().contains("BUSYGROUP")) {
+                log.info("group exists {}", stream);
+            } else {
+                throw e;
+            }
         }
     }