diff --git a/eventmesh-connectors/source-connector-s3/src/main/java/org/apache/eventmesh/source/connector/s3/S3SourceWorker.java b/eventmesh-connectors/source-connector-s3/src/main/java/org/apache/eventmesh/source/connector/s3/S3SourceWorker.java
index b0d2f322cb..9c3c3bb371 100644
--- a/eventmesh-connectors/source-connector-s3/src/main/java/org/apache/eventmesh/source/connector/s3/S3SourceWorker.java
+++ b/eventmesh-connectors/source-connector-s3/src/main/java/org/apache/eventmesh/source/connector/s3/S3SourceWorker.java
@@ -17,6 +17,15 @@
 
 package org.apache.eventmesh.source.connector.s3;
 
+import org.apache.eventmesh.openconnect.Application;
+import org.apache.eventmesh.source.connector.s3.connector.S3SourceConnector;
+
 public class S3SourceWorker {
 
+    public static void main(String[] args) throws Exception {
+
+        Application rocketmqSourceApp = new Application();
+        rocketmqSourceApp.run(S3SourceConnector.class);
+
+    }
 }