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)) {