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;
+            }
         }
     }