This is an automated email from the ASF dual-hosted git repository. gaoxihui pushed a commit to branch app-role-id-extend in repository https://gitbox.apache.org/repos/asf/ozhera.git
commit 16ecc4b6366a7591c64f3f4f6944005f9d5c1ba0 Merge: 2d0820cc b915d7f4 Author: gaoxh <[email protected]> AuthorDate: Tue Jan 20 14:35:51 2026 +0800 Merge branch 'master' into app-role-id-extend .../java/org/apache/ozhera/app/service/mq/RocketMqHeraAppConsumer.java | 1 + 1 file changed, 1 insertion(+) diff --cc ozhera-app/app-service/src/main/java/org/apache/ozhera/app/service/mq/RocketMqHeraAppConsumer.java index 7dfd4a39,20319273..25676adc --- a/ozhera-app/app-service/src/main/java/org/apache/ozhera/app/service/mq/RocketMqHeraAppConsumer.java +++ b/ozhera-app/app-service/src/main/java/org/apache/ozhera/app/service/mq/RocketMqHeraAppConsumer.java @@@ -252,13 -252,6 +252,14 @@@ public class RocketMqHeraAppConsumer List<String> members = membersP.stream().distinct().collect(Collectors.toList()); + log.info("check members size === " + members.size()); + + if(members.size() > 100){ + log.info("more than 100 members found from mq info by appId : {} and platform_type : {}, update members stop! ", appId, platFormType); + return; + } + ++ HeraAppRole role = new HeraAppRole(); role.setRole(0); role.setAppId(appId); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
