From 75b3292de820db7e241dddb147956a72db1f119a Mon Sep 17 00:00:00 2001 From: wangli <274027703@qq.com> Date: Thu, 23 Oct 2025 14:45:31 +0800 Subject: [PATCH] =?UTF-8?q?feat=20-=20=E8=B0=83=E6=95=B4debug=E6=B6=88?= =?UTF-8?q?=E8=B4=B9=E7=BB=84=E5=88=9B=E5=BB=BA=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../starter/WorkflowEngineStarterProperties.java | 12 ++++++++++++ .../condition/NonContainerEnvironmentCondition.java | 12 ++++++++++++ 2 files changed, 24 insertions(+) diff --git a/workflow-engine-spring-boot-starter/src/main/java/cn/axzo/workflow/starter/WorkflowEngineStarterProperties.java b/workflow-engine-spring-boot-starter/src/main/java/cn/axzo/workflow/starter/WorkflowEngineStarterProperties.java index ea95cd75b..9a3785419 100644 --- a/workflow-engine-spring-boot-starter/src/main/java/cn/axzo/workflow/starter/WorkflowEngineStarterProperties.java +++ b/workflow-engine-spring-boot-starter/src/main/java/cn/axzo/workflow/starter/WorkflowEngineStarterProperties.java @@ -41,6 +41,10 @@ public class WorkflowEngineStarterProperties { */ private Boolean joinContainerGroup = false; + /** + * 是否创建本地调试专用的 GID 消费组 + */ + private Boolean createDebugGroup = false; /** *

该参数只针对容器环境生效

* 配合 joinContainerGroup 使用,且只在 joinContainerGroup = false 时生效 @@ -116,6 +120,14 @@ public class WorkflowEngineStarterProperties { this.joinContainerGroup = joinContainerGroup; } + public Boolean getCreateDebugGroup() { + return createDebugGroup; + } + + public void setCreateDebugGroup(Boolean createDebugGroup) { + this.createDebugGroup = createDebugGroup; + } + public String getSpecialId() { return specialId; } diff --git a/workflow-engine-spring-boot-starter/src/main/java/cn/axzo/workflow/starter/common/condition/NonContainerEnvironmentCondition.java b/workflow-engine-spring-boot-starter/src/main/java/cn/axzo/workflow/starter/common/condition/NonContainerEnvironmentCondition.java index 153aafe0c..63fea01ab 100644 --- a/workflow-engine-spring-boot-starter/src/main/java/cn/axzo/workflow/starter/common/condition/NonContainerEnvironmentCondition.java +++ b/workflow-engine-spring-boot-starter/src/main/java/cn/axzo/workflow/starter/common/condition/NonContainerEnvironmentCondition.java @@ -44,6 +44,18 @@ public class NonContainerEnvironmentCondition implements Condition { return true; } + Boolean createDebugGroup = environment.getProperty("workflow.engine.starter.create-debug-group", Boolean.class); + if (Objects.isNull(createDebugGroup)) { + // 获取是否创建调试专用消费组 + createDebugGroup = new WorkflowEngineStarterProperties().getCreateDebugGroup(); + } + if (log.isDebugEnabled()) { + log.debug("workflow engine starter create-debug-group status: {} ", createDebugGroup); + } + if (!createDebugGroup) { + return false; + } + // 优先外部化配置 Boolean joinContainerGroup = environment.getProperty("workflow.engine.starter.join-container-group", Boolean.class); if (Objects.isNull(joinContainerGroup)) {