diff --git a/connectors/aliyun/rocketmq-connect-eventbridge/pom.xml b/connectors/aliyun/rocketmq-connect-eventbridge/pom.xml
index 57084ce6..508f117f 100644
--- a/connectors/aliyun/rocketmq-connect-eventbridge/pom.xml
+++ b/connectors/aliyun/rocketmq-connect-eventbridge/pom.xml
@@ -23,7 +23,6 @@
         <eventbridge-client.version>1.3.6</eventbridge-client.version>
         <aliyun-java-sdk-sts.version>3.1.0</aliyun-java-sdk-sts.version>
         <aliyun-java-sdk-core.version>4.6.0</aliyun-java-sdk-core.version>
-        <aliyun-java-sdk-sts-internal.version>3.0.0</aliyun-java-sdk-sts-internal.version>
         <gson.version>2.9.0</gson.version>
     </properties>
 
@@ -208,11 +207,6 @@
             <artifactId>aliyun-java-sdk-sts</artifactId>
             <version>${aliyun-java-sdk-sts.version}</version>
         </dependency>
-        <dependency>
-            <groupId>com.aliyun</groupId>
-            <artifactId>aliyun-java-sdk-sts-internal</artifactId>
-            <version>${aliyun-java-sdk-sts-internal.version}</version>
-        </dependency>
     </dependencies>
 
 </project>
\ No newline at end of file
diff --git a/connectors/aliyun/rocketmq-connect-eventbridge/src/main/java/org/apache/rocketmq/connect/eventbridge/sink/EventBridgeSinkTask.java b/connectors/aliyun/rocketmq-connect-eventbridge/src/main/java/org/apache/rocketmq/connect/eventbridge/sink/EventBridgeSinkTask.java
index 5c584735..2ace6e4f 100644
--- a/connectors/aliyun/rocketmq-connect-eventbridge/src/main/java/org/apache/rocketmq/connect/eventbridge/sink/EventBridgeSinkTask.java
+++ b/connectors/aliyun/rocketmq-connect-eventbridge/src/main/java/org/apache/rocketmq/connect/eventbridge/sink/EventBridgeSinkTask.java
@@ -9,8 +9,8 @@
 import com.aliyuncs.IAcsClient;
 import com.aliyuncs.http.FormatType;
 import com.aliyuncs.profile.DefaultProfile;
-import com.aliyuncs.sts.model.v20150401.AssumeRoleWithServiceIdentityRequest;
-import com.aliyuncs.sts.model.v20150401.AssumeRoleWithServiceIdentityResponse;
+import com.aliyuncs.sts.model.v20150401.AssumeRoleRequest;
+import com.aliyuncs.sts.model.v20150401.AssumeRoleResponse;
 import io.openmessaging.KeyValue;
 import io.openmessaging.connector.api.component.task.sink.SinkTask;
 import io.openmessaging.connector.api.component.task.sink.SinkTaskContext;
@@ -105,13 +105,12 @@ public void start(SinkTaskContext sinkTaskContext) {
                 DefaultProfile.addEndpoint("", "", "Sts", stsEndpoint);
                 DefaultProfile profile = DefaultProfile.getProfile("", accessKeyId, accessKeySecret);
                 IAcsClient client = new DefaultAcsClient(profile);
-                AssumeRoleWithServiceIdentityRequest request = new AssumeRoleWithServiceIdentityRequest();
+                AssumeRoleRequest request = new AssumeRoleRequest();
                 request.setRoleArn(roleArn);
                 request.setRoleSessionName(roleSessionName);
-                request.setAssumeRoleFor(roleSessionName);
                 request.setAcceptFormat(FormatType.JSON);
                 request.setDurationSeconds(3600L);
-                final AssumeRoleWithServiceIdentityResponse response = client.getAcsResponse(request);
+                final AssumeRoleResponse response = client.getAcsResponse(request);
                 authConfig.accessKeyId = response.getCredentials().getAccessKeyId();
                 authConfig.accessKeySecret = response.getCredentials().getAccessKeySecret();
                 authConfig.securityToken = response.getCredentials().getSecurityToken();