You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ozhera.apache.org by ga...@apache.org on 2026/01/20 06:35:55 UTC
(ozhera) 01/01: Merge branch 'master' into app-role-id-extend
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 <32...@users.noreply.github.com>
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: commits-unsubscribe@ozhera.apache.org
For additional commands, e-mail: commits-help@ozhera.apache.org