feat: add intelligent configuration detection feature

CHANGES.md

@@ -6,6 +6,7 @@ Apollo 3.0.0
 
 ------------------
 * [Fix: include super admin in hasAnyPermission semantics](https://github.com/apolloconfig/apollo/pull/5568)
-
+* [Feature: add intelligent configuration detection feature](https://github.com/apolloconfig/apollo/pull/5582)
+* 
 ------------------
 All issues and pull requests are [here](https://github.com/apolloconfig/apollo/milestone/18?closed=1)

apollo-assembly/src/main/resources/application.yml

@@ -75,3 +75,20 @@ server:
       cookie:
         # prevent csrf
         same-site: Lax
+
+
+# Intelligent Detection Configuration
+apollo:
+  detection:
+    enabled: false
+    active-provider: qwen
+    timeout: 30000
+    providers:
+      openai:
+        api-key: ${OPENAI_API_KEY:}
+        base-url: https://api.openai.com/v1
+        model: gpt-4o
+      qwen:
+        api-key: ${QWEN_API_KEY:}
+        base-url: https://dashscope.aliyuncs.com/compatible-mode/v1
+        model: qwen-plus

apollo-portal/pom.xml

@@ -137,6 +137,15 @@
 		</dependency>
 		<!-- end of test -->
 
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-webflux</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.fasterxml.jackson.core</groupId>
+            <artifactId>jackson-databind</artifactId>
+        </dependency>
+
 	</dependencies>
 	<build>
 		<!-- openapi-generator configuration -->

apollo-portal/src/main/java/com/ctrip/framework/apollo/portal/controller/ItemDetectionController.java

@@ -0,0 +1,105 @@
+/*
+ * Copyright 2026 Apollo Authors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+package com.ctrip.framework.apollo.portal.controller;
+
+
+import com.ctrip.framework.apollo.portal.service.config.detection.ConfigDetectionService;
+import com.ctrip.framework.apollo.portal.service.config.detection.model.DetectionRequest;
+import jakarta.servlet.http.HttpServletResponse;
+import org.springframework.web.bind.annotation.*;
+
+import java.io.IOException;
+import java.io.PrintWriter;
+
+/**
+ * Item detection controller for intelligent configuration detection
+ */
+@RestController
+@RequestMapping("/apps/{appId}/envs/{env}/clusters/{clusterName}/namespaces/{namespaceName}")
+public class ItemDetectionController {
+
+    private final ConfigDetectionService configDetectionService;
+
+    public ItemDetectionController(ConfigDetectionService configDetectionService) {
+        this.configDetectionService = configDetectionService;
+    }
+
+    @GetMapping(value = "/items/intelligent-detection")
+    public void detectConfigStream(
+            @PathVariable String appId,
+            @PathVariable String env,
+            @PathVariable String clusterName,
+            @PathVariable String namespaceName,
+            @RequestParam String key,
+            @RequestParam String value,
+            @RequestParam(required = false) String comment,
+            HttpServletResponse response) throws IOException {
+
+        response.setContentType("text/event-stream;charset=UTF-8");
+        response.setCharacterEncoding("UTF-8");
+        response.setHeader("Cache-Control", "no-cache");
+        response.setHeader("Connection", "keep-alive");
+
+        PrintWriter writer = response.getWriter();
+
+        DetectionRequest request = DetectionRequest.builder()
+                .appId(appId)
+                .env(env)
+                .clusterName(clusterName)
+                .namespaceName(namespaceName)
+                .key(key)
+                .value(value)
+                .comment(comment)
+                .build();
+
+        configDetectionService.detectStream(request)
+                .doOnNext(chunk -> {
+                    try {
+                        String[] lines = chunk.split("\n", -1);
+                        writer.write("event: message\n");
+                        for (String line : lines) {
+                            writer.write("data: " + line + "\n");
+                        }
+                        writer.write("\n");
+                        writer.flush();
+                    } catch (Exception e) {
+                        e.printStackTrace();
+                    }
+                })
+                .doOnComplete(() -> {
+                    try {
+                        writer.write("event: done\n");
+                        writer.write("data: [DONE]\n\n");
+                        writer.flush();
+                        writer.close();
+                    } catch (Exception e) {
+                        e.printStackTrace();
+                    }
+                })
+                .doOnError(e -> {
+                    try {
+                        writer.write("event: error\n");
+                        writer.write("data: check error：" + e.getMessage() + "\n\n");
+                        writer.flush();
+                        writer.close();
+                    } catch (Exception ex) {
+                        ex.printStackTrace();
+                    }
+                })
+                .blockLast();
+    }
+}

apollo-portal/src/main/java/com/ctrip/framework/apollo/portal/controller/PageSettingController.java

@@ -18,16 +18,20 @@
 
 import com.ctrip.framework.apollo.portal.component.config.PortalConfig;
 import com.ctrip.framework.apollo.portal.entity.vo.PageSetting;
+import com.ctrip.framework.apollo.portal.service.config.detection.config.DetectionProperties;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RestController;
 
 @RestController
 public class PageSettingController {
 
   private final PortalConfig portalConfig;
+  private final DetectionProperties detectionProperties;
 
-  public PageSettingController(final PortalConfig portalConfig) {
+  public PageSettingController(final PortalConfig portalConfig,
+                               final DetectionProperties detectionProperties) {
     this.portalConfig = portalConfig;
+    this.detectionProperties = detectionProperties;
   }
 
   @GetMapping("/page-settings")
@@ -36,6 +40,7 @@ public PageSetting getPageSetting() {
 
     setting.setWikiAddress(portalConfig.wikiAddress());
     setting.setCanAppAdminCreatePrivateNamespace(portalConfig.canAppAdminCreatePrivateNamespace());
+    setting.setDetectionEnabled(detectionProperties.isEnabled());
 
     return setting;
   }

apollo-portal/src/main/java/com/ctrip/framework/apollo/portal/entity/vo/PageSetting.java

@@ -22,6 +22,8 @@ public class PageSetting {
 
   private boolean canAppAdminCreatePrivateNamespace;
 
+  private boolean detectionEnabled;
+
   public String getWikiAddress() {
     return wikiAddress;
   }
@@ -37,4 +39,12 @@ public boolean isCanAppAdminCreatePrivateNamespace() {
   public void setCanAppAdminCreatePrivateNamespace(boolean canAppAdminCreatePrivateNamespace) {
     this.canAppAdminCreatePrivateNamespace = canAppAdminCreatePrivateNamespace;
   }
+
+  public boolean isDetectionEnabled() {
+    return detectionEnabled;
+  }
+
+  public void setDetectionEnabled(boolean detectionEnabled) {
+    this.detectionEnabled = detectionEnabled;
+  }
 }

apollo-portal/src/main/java/com/ctrip/framework/apollo/portal/service/config/detection/ConfigDetectionService.java

@@ -0,0 +1,83 @@
+/*
+ * Copyright 2026 Apollo Authors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+package com.ctrip.framework.apollo.portal.service.config.detection;
+
+
+import com.ctrip.framework.apollo.portal.service.config.detection.adapter.DetectionModelAdapter;
+import com.ctrip.framework.apollo.portal.service.config.detection.adapter.DetectionModelAdapterFactory;
+import com.ctrip.framework.apollo.portal.service.config.detection.config.DetectionProperties;
+import com.ctrip.framework.apollo.portal.service.config.detection.model.ChatMessage;
+import com.ctrip.framework.apollo.portal.service.config.detection.model.ChatRequest;
+import com.ctrip.framework.apollo.portal.service.config.detection.model.DetectionRequest;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Service;
+import reactor.core.publisher.Flux;
+
+import java.util.Arrays;
+import java.util.Map;
+
+/**
+ * Configuration detection service
+ */
+@Service
+public class ConfigDetectionService {
+
+    private static final Logger logger = LoggerFactory.getLogger(ConfigDetectionService.class);
+
+    private final DetectionProperties properties;
+    private final DetectionModelAdapterFactory adapterFactory;
+    private final PromptBuilder promptBuilder;
+
+    public ConfigDetectionService(
+            DetectionProperties properties,
+            DetectionModelAdapterFactory adapterFactory,
+            PromptBuilder promptBuilder) {
+        this.properties = properties;
+        this.adapterFactory = adapterFactory;
+        this.promptBuilder = promptBuilder;
+    }
+
+    public Flux<String> detectStream(DetectionRequest request) {
+        if (!properties.isEnabled()) {
+            return Flux.error(new IllegalStateException("Detection is not enabled"));
+        }
+        try {
+            String provider = properties.getActiveProvider();
+            logger.info("Starting detection for key: {}, provider: {}", request.getKey(), provider);
+            DetectionModelAdapter adapter = adapterFactory.getAdapter(provider);
+            String systemPrompt = promptBuilder.getSystemPrompt();
+            String userPrompt = promptBuilder.buildDetectionPrompt(request);
+
+            ChatRequest chatRequest = ChatRequest.builder()
+                    .messages(Arrays.asList(
+                            new ChatMessage("system", systemPrompt),
+                            new ChatMessage("user", userPrompt)
+                    ))
+                    .stream(true)
+                    .build();
+
+            return adapter.streamChat(chatRequest)
+                    .doOnComplete(() -> logger.info("Detection completed for key: {}", request.getKey()))
+                    .doOnError(error -> logger.error("Detection failed for key: {}", request.getKey(), error));
+
+        } catch (Exception e) {
+            logger.error("Failed to start detection", e);
+            return Flux.error(e);
+        }
+    }
+}