diff --git a/.github/actions/common/plugin-change-check/action.yml b/.github/actions/common/plugin-change-check/action.yml
index cf88e6842f..efe84455ca 100644
--- a/.github/actions/common/plugin-change-check/action.yml
+++ b/.github/actions/common/plugin-change-check/action.yml
@@ -530,6 +530,14 @@ runs:
       id: changed-dubbo-common-action
       with:
         paths: ./.github/actions/scenarios/dubbo/dubbo-common ./.github/actions/common/dubbo ./.github/workflows/dubbo_integration_test.yml
+    - uses: ktamas77/has-changed-path@v1.0.3
+      id: changed-dubbo3-flow-action
+      with:
+        paths: ./.github/actions/scenarios/dubbo/flow-dubbo3 ./.github/actions/common/dubbo ./.github/workflows/dubbo_integration_test.yml
+    - name: env dubbo3-flow-action
+      shell: bash
+      run: |
+        echo "enableDubbo3FlowActionChange=${{ steps.changed-dubbo3-flow-action.outputs.changed }}" >> $GITHUB_ENV
     - name: env dubbo-router-action
       shell: bash
       run: |
@@ -678,6 +686,13 @@ runs:
           echo "enableDubboLane=true" >> $GITHUB_ENV
           echo "enableDubbo3Lane=true" >> $GITHUB_ENV
         fi
+        # ==========dubbo3 flow is needed to test?==========
+        if [ ${{ env.sermantAgentCoreChanged }} == 'true' -o ${{ env.sermantFlowcontrolChanged }} == 'true' -o \
+            ${{ env.enableDubbo3FlowActionChange }} == 'true' -o \
+            ${{ steps.changed-common-action.outputs.changed }} == 'true' -o ${{ env.triggerPushEvent }} == 'true' -o \
+            ${{ env.enableDubboTestChange }} == 'true' ];then
+          echo "enableDubbo3Flow=true" >> $GITHUB_ENV
+        fi
 
         # *****************spring_integration_test_1.yml*****************
         # ==========graceful is needed to test?==========
diff --git a/.github/actions/scenarios/dubbo/dubbo3-flow/action.yml b/.github/actions/scenarios/dubbo/dubbo3-flow/action.yml
new file mode 100644
index 0000000000..5d69c355ba
--- /dev/null
+++ b/.github/actions/scenarios/dubbo/dubbo3-flow/action.yml
@@ -0,0 +1,60 @@
+name: "Dubbo3 Flow Test"
+description: "Auto test for dubbo3 flow"
+runs:
+  using: "composite"
+  steps:
+    - name: entry
+      uses: ./.github/actions/common/entry
+      with:
+        log-dir: ./logs/dubbo3-flow
+    - name: package dubbo 3.2.x tests
+      shell: bash
+      if: matrix.dubbo-version == '3-2'
+      run: mvn package -Ddubbo.version=3.2.${{ matrix.dubbo-versions }} -DskipTests --file sermant-integration-tests/dubbo-test/pom.xml
+    - name: start provider service
+      shell: bash
+      env:
+        SERVER_PORT: 28022
+        DUBBO_PROTOCOL_PORT: 28822
+      run: |
+        nohup java -javaagent:sermant-agent-${{ env.sermantVersion }}/agent/sermant-agent.jar=appName=dubbo-integration-provider -jar \
+        sermant-integration-tests/dubbo-test/dubbo-${{ env.projectPath }}-integration-provider/target/dubbo-integration-provider.jar > ${{ env.logDir }}/dubbo-provider.log 2>&1 &
+    - name: waiting for providers start
+      shell: bash
+      run: |
+        bash ./sermant-integration-tests/scripts/checkService.sh http://127.0.0.1:28022/actuator/health 120
+    - name: start consumer service
+      shell: bash
+      env:
+        SERVER_PORT: 28020
+        DUBBO_PROTOCOL_PORT: 28820
+      run: |
+        nohup java -javaagent:sermant-agent-${{ env.sermantVersion }}/agent/sermant-agent.jar=appName=dubbo-integration-consumer -jar \
+        sermant-integration-tests/dubbo-test/dubbo-${{ env.projectPath }}-integration-consumer/target/dubbo-integration-consumer.jar > ${{ env.logDir }}/dubbo-consumer.log 2>&1 &
+    - name: waiting for consumers start
+      shell: bash
+      run: |
+        bash ./sermant-integration-tests/scripts/checkService.sh http://127.0.0.1:28020/actuator/health 120
+    - name: integration test
+      shell: bash
+      env:
+        TEST_TYPE: dubbo3-flow
+      run: mvn test --file sermant-integration-tests/dubbo-test/pom.xml
+    - name: mvn clean
+      shell: bash
+      run: mvn clean --file sermant-integration-tests/dubbo-test/pom.xml
+    - name: exit
+      if: always()
+      uses: ./.github/actions/common/exit
+      with:
+        processor-keyword: dubbo
+    - name: if failure then upload error log
+      uses: actions/upload-artifact@v4
+      if: ${{ failure() || cancelled() }}
+      with:
+        name: (test-for-dubbo3-flow)-(${{ matrix.dubbo-version }}-${{ matrix.dubbo-versions }})-logs
+        path: |
+          ./*.log
+          ./logs/**/*.log
+        if-no-files-found: warn
+        retention-days: 2
diff --git a/.github/workflows/dubbo_integration_test.yml b/.github/workflows/dubbo_integration_test.yml
index 2d0bbb35bf..45d0812cbf 100644
--- a/.github/workflows/dubbo_integration_test.yml
+++ b/.github/workflows/dubbo_integration_test.yml
@@ -48,6 +48,7 @@ jobs:
           echo "enableDubboRemoval=${{env.enableDubboRemoval}}" >> $GITHUB_OUTPUT
           echo "enableDubbo3Router=${{env.enableDubbo3Router}}" >> $GITHUB_OUTPUT
           echo "enableDubbo3Lane=${{env.enableDubbo3Lane}}" >> $GITHUB_OUTPUT
+          echo "enableDubbo3Flow=${{env.enableDubbo3Flow}}" >> $GITHUB_OUTPUT
     outputs:
       enableDubboRouter: ${{ steps.set-outputs.outputs.enableDubboRouter }}
       enableDubboMonitor: ${{ steps.set-outputs.outputs.enableDubboMonitor }}
@@ -57,6 +58,7 @@ jobs:
       enableDubboRemoval: ${{ steps.set-outputs.outputs.enableDubboRemoval }}
       enableDubbo3Router: ${{ steps.set-outputs.outputs.enableDubbo3Router }}
       enableDubbo3Lane: ${{ steps.set-outputs.outputs.enableDubbo3Lane }}
+      enableDubbo3Flow: ${{ steps.set-outputs.outputs.enableDubbo3Flow }}
   download-midwares-and-cache:
     name: download and cache middlewares
     runs-on: ubuntu-latest
@@ -152,7 +154,7 @@ jobs:
         uses: ./.github/actions/scenarios/dubbo/removal
   test-for-dubbo3:
     name: Test for dubbo3.x
-    if: needs.set-execution-conditions.outputs.enableDubbo3Router == 'true' || needs.set-execution-conditions.outputs.enableDubbo3Lane == 'true'
+    if: needs.set-execution-conditions.outputs.enableDubbo3Router == 'true' || needs.set-execution-conditions.outputs.enableDubbo3Lane == 'true' || needs.set-execution-conditions.outputs.enableDubbo3Flow == 'true'
     runs-on: ubuntu-latest
     needs: [set-execution-conditions, download-midwares-and-cache, build-agent-and-cache ]
     strategy:
@@ -241,3 +243,9 @@ jobs:
       - name: (dubbo3.x lane) test for ${{ matrix.dubbo-version }}-${{ matrix.dubbo-versions }}
         if: needs.set-execution-conditions.outputs.enableDubbo3Lane == 'true'
         uses: ./.github/actions/scenarios/dubbo/lane-dubbo3
+      - name: (dubbo3.x flow) test for ${{ matrix.dubbo-version }}-${{ matrix.dubbo-versions }}
+        # The server passes the limiting, circuit-breaker, and bulkhead tests with dubbo 3.0.x-3.3.x version.
+        # The client passes the limiting, circuit-breaker, retry, faultInjection and bulkhead tests with dubbo 3.2.x-3.3.x version.
+        # Dubbo 3.0.x-3.1.x client request does not load the default filter.
+        if: needs.set-execution-conditions.outputs.enableDubbo3Flow == 'true' && matrix.dubbo-version == '3-2'
+        uses: ./.github/actions/scenarios/dubbo/dubbo3-flow
diff --git a/sermant-integration-tests/dubbo-test/dubbo-2-7-integration-consumer/src/main/java/io/sermant/integration/controller/FlowHeaderController.java b/sermant-integration-tests/dubbo-test/dubbo-2-7-integration-consumer/src/main/java/io/sermant/integration/controller/FlowHeaderController.java
index 759c5fdf0a..8ace0dbf3e 100644
--- a/sermant-integration-tests/dubbo-test/dubbo-2-7-integration-consumer/src/main/java/io/sermant/integration/controller/FlowHeaderController.java
+++ b/sermant-integration-tests/dubbo-test/dubbo-2-7-integration-consumer/src/main/java/io/sermant/integration/controller/FlowHeaderController.java
@@ -25,6 +25,8 @@
 import org.springframework.web.bind.annotation.RestController;
 
 import java.util.Collections;
+import java.util.HashMap;
+import java.util.Map;
 
 import javax.annotation.Resource;
 
@@ -55,7 +57,9 @@ public String rateLimitingWithHeader(@RequestParam(name = "key") String key, @Re
         try {
             RpcContext.getContext().setAttachment(key, value);
             RpcContext.getContext().setAttachment(key2, value2);
-            return flowControlService.rateLimitingWithHeader(Collections.singletonMap(key, value));
+            Map<String, Object> attachments = new HashMap<>();
+            attachments.put(key, value);
+            return flowControlService.rateLimitingWithHeader(attachments);
         } finally {
             RpcContext.getContext().remove(key);
             RpcContext.getContext().remove(key2);
diff --git a/sermant-integration-tests/dubbo-test/dubbo-integration-test/src/test/java/io/sermant/integration/flow/dubbo3/Dubbo3FlowControlTest.java b/sermant-integration-tests/dubbo-test/dubbo-integration-test/src/test/java/io/sermant/integration/flow/dubbo3/Dubbo3FlowControlTest.java
new file mode 100644
index 0000000000..e60ce9a345
--- /dev/null
+++ b/sermant-integration-tests/dubbo-test/dubbo-integration-test/src/test/java/io/sermant/integration/flow/dubbo3/Dubbo3FlowControlTest.java
@@ -0,0 +1,212 @@
+/*
+ * Copyright (C) 2025-2025 Sermant Authors. All rights reserved.
+ *
+ *   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 io.sermant.integration.flow.dubbo3;
+
+import java.util.Collections;
+import java.util.concurrent.ArrayBlockingQueue;
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.ThreadPoolExecutor;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.atomic.AtomicBoolean;
+
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.condition.EnabledIfEnvironmentVariable;
+
+import io.sermant.integration.utils.RequestUtils;
+
+/**
+ * flow tests
+ *
+ * @author chengyouling
+ * @since 2025-02-19
+ */
+@EnabledIfEnvironmentVariable(named = "TEST_TYPE", matches = "dubbo3-flow")
+public class Dubbo3FlowControlTest {
+    private static final String BASE_URL = "http://127.0.0.1:28020/consumer/flow/";
+    private static final int RATE_LIMITING_REQUEST_COUNT = 10;
+    private static final int BREAKER_REQUEST_COUNT = 10;
+    private static final String BREAKER_MSG = "is OPEN and does not permit further calls";
+    private static final String RATE_LIMITING_MSG = "Rate Limited";
+
+    /**
+     * 限流测试
+     */
+    @Test
+    public void testRateLimiting() {
+        rateTest("rateLimiting");
+        rateTest("rateLimitingPrefix");
+        rateTest("rateLimitingSuffix");
+        rateTest("rateLimitingContains");
+    }
+
+    /**
+     * 限流测试-应用匹配测试
+     */
+    @Test
+    public void testRateLimitingWithApplication() {
+        rateTest("rateLimitingWithApplication");
+    }
+
+    /**
+     * 限流测试-应用匹配测试
+     */
+    @Test
+    public void testRateLimitingWithHeader() {
+        rateTest("rateLimitingWithHeader?key=key&value=attachment&key2=key2&value2=999");
+        rateTest("rateLimitingWithHeader?key=key&value=flowControlExact&key2=key2&value2=999");
+        rateTest("rateLimitingWithHeader?key=key&value=flowControlPrefix&key2=key2&value2=999");
+        rateTest("rateLimitingWithHeader?key=key&value=flowControlSuffix&key2=key2&value2=999");
+        rateTest("rateLimitingWithHeader?key=key&value=flowControlContains&key2=key2&value2=999");
+        rateTest("rateLimitingWithHeader?key=key&value=101&key2=key2&value2=999");
+        final AtomicBoolean check = new AtomicBoolean();
+        process("rateLimitingWithHeader?key=key&value=val&key2=key2&value2=998", RATE_LIMITING_MSG,
+            RATE_LIMITING_REQUEST_COUNT, check);
+        Assertions.assertFalse(check.get());
+    }
+
+    /**
+     * 限流测试-版本测试
+     */
+    @Test
+    public void testRateLimitingWithVersion() {
+        rateTest("rateLimitingWithVersion");
+    }
+
+    /**
+     * 测试熔断-慢调用熔断
+     */
+    @Test
+    public void cirEx() {
+        test("cirEx", BREAKER_MSG, BREAKER_REQUEST_COUNT);
+    }
+
+    /**
+     * 实例隔离-慢调用熔断
+     */
+    @Test
+    public void instanceSlowInvoker() {
+        test("instanceSlowInvoker", BREAKER_MSG, BREAKER_REQUEST_COUNT);
+    }
+
+    /**
+     * 实例隔离-异常
+     */
+    @Test
+    public void instanceEx() {
+        test("instanceEx", BREAKER_MSG, BREAKER_REQUEST_COUNT);
+    }
+
+    /**
+     * 错误注入-返回空
+     */
+    @Test
+    public void faultNull() {
+        final String result = RequestUtils.get(BASE_URL + "faultNull", Collections.emptyMap(), String.class);
+        Assertions.assertNull(result);
+    }
+
+    /**
+     * 错误注入-抛异常
+     */
+    @Test
+    public void faultThrowEx() {
+        test("faultThrowEx", "Request has been aborted by fault-ThrowException", 1);
+    }
+
+    /**
+     * 错误注入-返回空
+     */
+    @Test
+    public void faultDelay() {
+        final long start = System.currentTimeMillis();
+        long delay = 2000L;
+        RequestUtils.get(BASE_URL + "faultDelay", Collections.emptyMap(), String.class);
+        Assertions.assertTrue((System.currentTimeMillis() - start) >= delay);
+    }
+
+    /**
+     * 隔离仓测试
+     */
+    @Test
+    public void bulkHead() throws InterruptedException {
+        final ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(5, 5, 0, TimeUnit.MILLISECONDS,
+            new ArrayBlockingQueue<>(100));
+        int cycle = 5;
+        final CountDownLatch countDownLatch = new CountDownLatch(cycle);
+        final AtomicBoolean expected = new AtomicBoolean();
+        for (int i = 0; i < cycle; i++) {
+            threadPoolExecutor.execute(() -> {
+                try {
+                    process("/bulkhead", "Bulkhead is full and does not permit further calls",
+                        RATE_LIMITING_REQUEST_COUNT, expected);
+                } finally {
+                    countDownLatch.countDown();
+                }
+            });
+        }
+        countDownLatch.await();
+        Assertions.assertTrue(expected.get());
+        threadPoolExecutor.shutdown();
+    }
+
+    /**
+     * 重试
+     */
+    @Test
+    public void retry() {
+        final String result = RequestUtils.get(BASE_URL + "retry", Collections.emptyMap(), String.class);
+        Assertions.assertEquals(result, "3");
+    }
+
+    /**
+     * 测试熔断-异常
+     */
+    @Test
+    public void cirSlowInvoker() {
+        test("cirSlowInvoker", BREAKER_MSG, BREAKER_REQUEST_COUNT);
+    }
+
+    private void rateTest(String api) {
+        test(api, RATE_LIMITING_MSG, RATE_LIMITING_REQUEST_COUNT);
+    }
+
+    private void test(String api, String msg, int requestCount) {
+        final AtomicBoolean check = new AtomicBoolean();
+        process(api, msg, requestCount, check);
+        Assertions.assertTrue(check.get());
+    }
+
+    private void process(String api, String flowControlMsg, int requestCount, AtomicBoolean check) {
+        String url = BASE_URL + api;
+        for (int i = 0; i < requestCount; i++) {
+            try {
+                RequestUtils.get(url, Collections.emptyMap(), String.class,
+                    (clientHttpResponse, result) -> {
+                        if (result.contains(flowControlMsg)) {
+                            check.set(true);
+                        }
+                        return result;
+                    });
+            } catch (Exception ex) {
+                if (ex.getMessage().contains(flowControlMsg)) {
+                    check.set(true);
+                }
+            }
+        }
+    }
+}
diff --git a/sermant-plugins/sermant-flowcontrol/flowcontrol-common/src/main/java/io/sermant/flowcontrol/common/util/DubboAttachmentsHelper.java b/sermant-plugins/sermant-flowcontrol/flowcontrol-common/src/main/java/io/sermant/flowcontrol/common/util/DubboAttachmentsHelper.java
index c841e1e115..18e135b22f 100644
--- a/sermant-plugins/sermant-flowcontrol/flowcontrol-common/src/main/java/io/sermant/flowcontrol/common/util/DubboAttachmentsHelper.java
+++ b/sermant-plugins/sermant-flowcontrol/flowcontrol-common/src/main/java/io/sermant/flowcontrol/common/util/DubboAttachmentsHelper.java
@@ -18,6 +18,8 @@
 
 import io.sermant.core.utils.ReflectUtils;
 
+import org.apache.dubbo.common.Version;
+
 import java.util.Collections;
 import java.util.HashMap;
 import java.util.Map;
@@ -38,6 +40,12 @@ public class DubboAttachmentsHelper {
 
     private static final String GET_CONTEXT_METHOD = "getContext";
 
+    private static final String GET_SERVER_ATTACHMENT_METHOD = "getServerAttachment";
+
+    private static final String GET_CLIENT_ATTACHMENT_METHOD = "getClientAttachment";
+
+    private static final String DUBBO_3X_PREFIX = "3.";
+
     private DubboAttachmentsHelper() {
     }
 
@@ -46,17 +54,30 @@ private DubboAttachmentsHelper() {
      *
      * @param invocation call information
      * @param isApache whether it is apache dubbo
+     * @param isProvider whether it is dubbo server
      * @return Map
      */
-    public static Map<String, String> resolveAttachments(Object invocation, boolean isApache) {
+    public static Map<String, String> resolveAttachments(Object invocation, boolean isApache, boolean isProvider) {
         if (invocation == null) {
             return Collections.emptyMap();
         }
+        String dubboVersion = invocation.getClass().getPackage().getImplementationVersion();
+        if (dubboVersion == null) {
+            dubboVersion = Version.getVersion();
+        }
         final Map<String, String> attachments = new HashMap<>();
         if (isApache) {
-            attachments.putAll(getAttachmentsFromContext(APACHE_RPC_CONTEXT));
+            if (dubboVersion.startsWith(DUBBO_3X_PREFIX)) {
+                if (isProvider) {
+                    attachments.putAll(getAttachmentsFromContext(APACHE_RPC_CONTEXT, GET_SERVER_ATTACHMENT_METHOD));
+                } else {
+                    attachments.putAll(getAttachmentsFromContext(APACHE_RPC_CONTEXT, GET_CLIENT_ATTACHMENT_METHOD));
+                }
+            } else {
+                attachments.putAll(getAttachmentsFromContext(APACHE_RPC_CONTEXT, GET_CONTEXT_METHOD));
+            }
         } else {
-            attachments.putAll(getAttachmentsFromContext(ALIBABA_RPC_CONTEXT));
+            attachments.putAll(getAttachmentsFromContext(ALIBABA_RPC_CONTEXT, GET_CONTEXT_METHOD));
         }
         final Optional<Object> fieldValue = ReflectUtils.getFieldValue(invocation, ATTACHMENTS_FIELD);
         if (fieldValue.isPresent() && fieldValue.get() instanceof Map) {
@@ -65,8 +86,8 @@ public static Map<String, String> resolveAttachments(Object invocation, boolean
         return Collections.unmodifiableMap(attachments);
     }
 
-    private static Map<String, String> getAttachmentsFromContext(String contextClazz) {
-        final Optional<Object> context = ReflectUtils.invokeMethod(contextClazz, GET_CONTEXT_METHOD, null,
+    private static Map<String, String> getAttachmentsFromContext(String contextClazz, String methodName) {
+        final Optional<Object> context = ReflectUtils.invokeMethod(contextClazz, methodName, null,
                 null);
         if (!context.isPresent()) {
             return Collections.emptyMap();
diff --git a/sermant-plugins/sermant-flowcontrol/flowcontrol-common/src/test/java/io/sermant/flowcontrol/common/util/DubboAttachmentsHelperTest.java b/sermant-plugins/sermant-flowcontrol/flowcontrol-common/src/test/java/io/sermant/flowcontrol/common/util/DubboAttachmentsHelperTest.java
index 3a3773eb66..602ec5a50a 100644
--- a/sermant-plugins/sermant-flowcontrol/flowcontrol-common/src/test/java/io/sermant/flowcontrol/common/util/DubboAttachmentsHelperTest.java
+++ b/sermant-plugins/sermant-flowcontrol/flowcontrol-common/src/test/java/io/sermant/flowcontrol/common/util/DubboAttachmentsHelperTest.java
@@ -33,9 +33,9 @@
 public class DubboAttachmentsHelperTest {
     @Test
     public void testNull() {
-        final Map<String, String> map = DubboAttachmentsHelper.resolveAttachments(null, false);
+        final Map<String, String> map = DubboAttachmentsHelper.resolveAttachments(null, false, true);
         Assert.assertEquals(map, Collections.emptyMap());
-        final Map<String, String> map2 = DubboAttachmentsHelper.resolveAttachments(null, true);
+        final Map<String, String> map2 = DubboAttachmentsHelper.resolveAttachments(null, true, true);
         Assert.assertEquals(map2, Collections.emptyMap());
     }
 
@@ -45,7 +45,7 @@ public void testAlibabaInvocation() {
         String key = "a";
         String value = "c";
         com.alibaba.dubbo.rpc.RpcContext.getContext().getAttachments().put(key, value);
-        final Map<String, String> map = DubboAttachmentsHelper.resolveAttachments(testStringInvocation, false);
+        final Map<String, String> map = DubboAttachmentsHelper.resolveAttachments(testStringInvocation, false, false);
         Assert.assertEquals(map.get(key), value);
         com.alibaba.dubbo.rpc.RpcContext.getContext().getAttachments().clear();
     }
@@ -56,7 +56,7 @@ public void testApacheInvocation() {
         String key = "a";
         String value = "apache";
         RpcContext.getContext().getAttachments().put(key, value);
-        final Map<String, String> map = DubboAttachmentsHelper.resolveAttachments(testObjectInvocation, true);
+        final Map<String, String> map = DubboAttachmentsHelper.resolveAttachments(testObjectInvocation, true, false);
         Assert.assertEquals(map.get(key), value);
         RpcContext.getContext().getAttachments().clear();
     }
@@ -65,10 +65,10 @@ public void testApacheInvocation() {
     public void testStringAttachments() {
         final TestStringInvocation testStringInvocation = new TestStringInvocation(buildAttachments());
         final Map<String, String> attachmentsByString = DubboAttachmentsHelper
-                .resolveAttachments(testStringInvocation, false);
+                .resolveAttachments(testStringInvocation, false, false);
         Assert.assertEquals(attachmentsByString, testStringInvocation.attachments);
         final Map<String, String> attachmentsByString2 = DubboAttachmentsHelper
-                .resolveAttachments(testStringInvocation, true);
+                .resolveAttachments(testStringInvocation, true, false);
         Assert.assertEquals(attachmentsByString2, testStringInvocation.attachments);
     }
 
@@ -90,10 +90,10 @@ private Map<String, Object> buildObjectAttachments() {
     public void testObjectAttachments() {
         final TestObjectInvocation testObjectInvocation = new TestObjectInvocation(buildObjectAttachments());
         final Map<String, String> attachmentsByObject = DubboAttachmentsHelper
-                .resolveAttachments(testObjectInvocation, false);
+                .resolveAttachments(testObjectInvocation, false, false);
         Assert.assertEquals(attachmentsByObject, testObjectInvocation.attachments);
         final Map<String, String> attachmentsByObject2 = DubboAttachmentsHelper
-                .resolveAttachments(testObjectInvocation, true);
+                .resolveAttachments(testObjectInvocation, true, false);
         Assert.assertEquals(attachmentsByObject2, testObjectInvocation.attachments);
     }
 
diff --git a/sermant-plugins/sermant-flowcontrol/flowcontrol-plugin/src/main/java/io/sermant/flowcontrol/AlibabaDubboInterceptor.java b/sermant-plugins/sermant-flowcontrol/flowcontrol-plugin/src/main/java/io/sermant/flowcontrol/AlibabaDubboInterceptor.java
index 3b8c605eae..b28fb8929d 100644
--- a/sermant-plugins/sermant-flowcontrol/flowcontrol-plugin/src/main/java/io/sermant/flowcontrol/AlibabaDubboInterceptor.java
+++ b/sermant-plugins/sermant-flowcontrol/flowcontrol-plugin/src/main/java/io/sermant/flowcontrol/AlibabaDubboInterceptor.java
@@ -83,7 +83,8 @@ private DubboRequestEntity convertToAlibabaDubboEntity(Invocation invocation, In
         // versions and interfaces are used here to achieve the same end result
         String apiPath = ConvertUtils.buildApiPath(interfaceName, version, methodName);
         final boolean isProvider = isProvider(curInvoker);
-        return new DubboRequestEntity(apiPath, DubboAttachmentsHelper.resolveAttachments(invocation, false),
+        return new DubboRequestEntity(apiPath,
+                DubboAttachmentsHelper.resolveAttachments(invocation, false, isProvider),
                 isProvider ? RequestType.SERVER : RequestType.CLIENT, getApplication(url, interfaceName, isProvider),
                 isGeneric);
     }
diff --git a/sermant-plugins/sermant-flowcontrol/flowcontrol-plugin/src/main/java/io/sermant/flowcontrol/ApacheDubboInterceptor.java b/sermant-plugins/sermant-flowcontrol/flowcontrol-plugin/src/main/java/io/sermant/flowcontrol/ApacheDubboInterceptor.java
index 4f93913cd4..73a740ba15 100644
--- a/sermant-plugins/sermant-flowcontrol/flowcontrol-plugin/src/main/java/io/sermant/flowcontrol/ApacheDubboInterceptor.java
+++ b/sermant-plugins/sermant-flowcontrol/flowcontrol-plugin/src/main/java/io/sermant/flowcontrol/ApacheDubboInterceptor.java
@@ -91,7 +91,8 @@ private DubboRequestEntity convertToApacheDubboEntity(Invocation invocation, Inv
         // versions and interfaces are used here to achieve the same end result
         String apiPath = ConvertUtils.buildApiPath(interfaceName, version, methodName);
         final boolean isProvider = isProvider(curInvoker);
-        return new DubboRequestEntity(apiPath, DubboAttachmentsHelper.resolveAttachments(invocation, true),
+        return new DubboRequestEntity(apiPath,
+                DubboAttachmentsHelper.resolveAttachments(invocation, true, isProvider),
                 isProvider ? RequestType.SERVER : RequestType.CLIENT,
                 getApplication(url, interfaceName, isProvider), isGeneric);
     }
diff --git a/sermant-plugins/sermant-flowcontrol/flowcontrol-plugin/src/main/java/io/sermant/flowcontrol/ConsumerRpcExceptionFilterDeclarer.java b/sermant-plugins/sermant-flowcontrol/flowcontrol-plugin/src/main/java/io/sermant/flowcontrol/ConsumerRpcExceptionFilterDeclarer.java
new file mode 100644
index 0000000000..4371061521
--- /dev/null
+++ b/sermant-plugins/sermant-flowcontrol/flowcontrol-plugin/src/main/java/io/sermant/flowcontrol/ConsumerRpcExceptionFilterDeclarer.java
@@ -0,0 +1,37 @@
+/*
+ * Copyright (C) 2025-2025 Sermant Authors. All rights reserved.
+ *
+ *   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 io.sermant.flowcontrol;
+
+/**
+ * Intercept the invoke method of org.apache.dubbo.rpc.filter.RpcExceptionFilter
+ * for dubbo3.3.x consumer filter
+ *
+ * @author chengyouling
+ * @since 2025-02-27
+ */
+public class ConsumerRpcExceptionFilterDeclarer extends DubboDeclarer {
+    private static final String ENHANCE_CLASS = "org.apache.dubbo.rpc.filter.RpcExceptionFilter";
+
+    private static final String INTERCEPT_CLASS = ApacheDubboInterceptor.class.getCanonicalName();
+
+    /**
+     * apache dubbo Declarer
+     */
+    public ConsumerRpcExceptionFilterDeclarer() {
+        super(ENHANCE_CLASS, INTERCEPT_CLASS);
+    }
+}
diff --git a/sermant-plugins/sermant-flowcontrol/flowcontrol-plugin/src/main/java/io/sermant/flowcontrol/MetricsFilterDeclarer.java b/sermant-plugins/sermant-flowcontrol/flowcontrol-plugin/src/main/java/io/sermant/flowcontrol/MetricsFilterDeclarer.java
new file mode 100644
index 0000000000..140e7522ab
--- /dev/null
+++ b/sermant-plugins/sermant-flowcontrol/flowcontrol-plugin/src/main/java/io/sermant/flowcontrol/MetricsFilterDeclarer.java
@@ -0,0 +1,37 @@
+/*
+ * Copyright (C) 2025-2025 Sermant Authors. All rights reserved.
+ *
+ *   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 io.sermant.flowcontrol;
+
+/**
+ * Intercept the invoke method of org.apache.dubbo.metrics.filter.MetricsFilter
+ * for dubbo3.2 consumer
+ *
+ * @author chengyouling
+ * @since 2025-02-27
+ */
+public class MetricsFilterDeclarer extends DubboDeclarer {
+    private static final String ENHANCE_CLASS = "org.apache.dubbo.metrics.filter.MetricsFilter";
+
+    private static final String INTERCEPT_CLASS = ApacheDubboInterceptor.class.getCanonicalName();
+
+    /**
+     * apache dubbo Declarer
+     */
+    public MetricsFilterDeclarer() {
+        super(ENHANCE_CLASS, INTERCEPT_CLASS);
+    }
+}
diff --git a/sermant-plugins/sermant-flowcontrol/flowcontrol-plugin/src/main/java/io/sermant/flowcontrol/retry/cluster/AlibabaDubboClusterInvoker.java b/sermant-plugins/sermant-flowcontrol/flowcontrol-plugin/src/main/java/io/sermant/flowcontrol/retry/cluster/AlibabaDubboClusterInvoker.java
index 181bea568c..d414b2fe89 100644
--- a/sermant-plugins/sermant-flowcontrol/flowcontrol-plugin/src/main/java/io/sermant/flowcontrol/retry/cluster/AlibabaDubboClusterInvoker.java
+++ b/sermant-plugins/sermant-flowcontrol/flowcontrol-plugin/src/main/java/io/sermant/flowcontrol/retry/cluster/AlibabaDubboClusterInvoker.java
@@ -189,7 +189,8 @@ private DubboRequestEntity convertToAlibabaDubboEntity(Invocation invocation, In
         // High version using API invocation.getTargetServiceUniqueName access path，
         // versions and interfaces are used here to achieve the same end result
         String apiPath = ConvertUtils.buildApiPath(interfaceName, version, methodName);
-        return new DubboRequestEntity(apiPath, DubboAttachmentsHelper.resolveAttachments(invocation, false),
+        return new DubboRequestEntity(apiPath,
+                DubboAttachmentsHelper.resolveAttachments(invocation, false, false),
                 RequestType.CLIENT, getRemoteApplication(url, interfaceName), isGeneric);
     }
 
diff --git a/sermant-plugins/sermant-flowcontrol/flowcontrol-plugin/src/main/java/io/sermant/flowcontrol/retry/cluster/ApacheDubboClusterInvoker.java b/sermant-plugins/sermant-flowcontrol/flowcontrol-plugin/src/main/java/io/sermant/flowcontrol/retry/cluster/ApacheDubboClusterInvoker.java
index e9abdf7a21..5ff224107f 100644
--- a/sermant-plugins/sermant-flowcontrol/flowcontrol-plugin/src/main/java/io/sermant/flowcontrol/retry/cluster/ApacheDubboClusterInvoker.java
+++ b/sermant-plugins/sermant-flowcontrol/flowcontrol-plugin/src/main/java/io/sermant/flowcontrol/retry/cluster/ApacheDubboClusterInvoker.java
@@ -199,7 +199,8 @@ private DubboRequestEntity convertToApacheDubboEntity(Invocation invocation, Inv
         // High version using API invocation.getTargetServiceUniqueName access path，
         // versions and interfaces are used here to achieve the same end result
         String apiPath = ConvertUtils.buildApiPath(interfaceName, version, methodName);
-        return new DubboRequestEntity(apiPath, DubboAttachmentsHelper.resolveAttachments(invocation, true),
+        return new DubboRequestEntity(apiPath,
+                DubboAttachmentsHelper.resolveAttachments(invocation, true, false),
                 RequestType.CLIENT, getRemoteApplication(url, interfaceName), isGeneric);
     }
 
diff --git a/sermant-plugins/sermant-flowcontrol/flowcontrol-plugin/src/main/resources/META-INF/services/io.sermant.core.plugin.agent.declarer.PluginDeclarer b/sermant-plugins/sermant-flowcontrol/flowcontrol-plugin/src/main/resources/META-INF/services/io.sermant.core.plugin.agent.declarer.PluginDeclarer
index 4e692c9553..d6ee279b41 100644
--- a/sermant-plugins/sermant-flowcontrol/flowcontrol-plugin/src/main/resources/META-INF/services/io.sermant.core.plugin.agent.declarer.PluginDeclarer
+++ b/sermant-plugins/sermant-flowcontrol/flowcontrol-plugin/src/main/resources/META-INF/services/io.sermant.core.plugin.agent.declarer.PluginDeclarer
@@ -18,6 +18,8 @@
 io.sermant.flowcontrol.DispatcherServletDeclarer
 io.sermant.flowcontrol.AlibabaDubboDeclarer
 io.sermant.flowcontrol.ApacheDubboDeclarer
+io.sermant.flowcontrol.ConsumerRpcExceptionFilterDeclarer
+io.sermant.flowcontrol.MetricsFilterDeclarer
 io.sermant.flowcontrol.config.DubboServiceNameDeclarer
 io.sermant.flowcontrol.config.ApacheDubboConfigDeclarer
 io.sermant.flowcontrol.config.AlibabaDubboConfigDeclarer