|
|
@ -160,7 +160,11 @@ public class RedisStreamConsumer { |
|
|
.createGroup(stream, ReadOffset.from("0-0"), GROUP); |
|
|
.createGroup(stream, ReadOffset.from("0-0"), GROUP); |
|
|
log.info("create group success stream={}", stream); |
|
|
log.info("create group success stream={}", stream); |
|
|
} catch (Exception e) { |
|
|
} 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; |
|
|
|
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
|