fix gradle dependecy and add runtime v2

build.gradle

@@ -577,7 +577,7 @@ subprojects {
             dependency "org.mybatis.spring.boot:mybatis-spring-boot-starter:2.3.1"
             dependency "com.alibaba:druid-spring-boot-starter:1.2.22"
             dependency "org.springframework.boot:spring-boot-starter-jetty:2.7.10"
-
+            dependency "com.baomidou:mybatis-plus:3.5.6"
             dependency "com.mysql:mysql-connector-j:8.0.33"
 
         }

eventmesh-admin-server/build.gradle

@@ -3,6 +3,7 @@ dependencies {
 	implementation project(":eventmesh-common")
 	implementation project(":eventmesh-registry:eventmesh-registry-api")
 	implementation project(":eventmesh-registry:eventmesh-registry-nacos")
+	implementation project(':eventmesh-openconnect:eventmesh-openconnect-offsetmgmt-plugin:eventmesh-openconnect-offsetmgmt-api')
 	implementation "com.alibaba.nacos:nacos-client"
 	implementation ("org.springframework.boot:spring-boot-starter-web") {
 		exclude group: "org.springframework.boot", module: "spring-boot-starter-tomcat"
@@ -11,9 +12,12 @@ dependencies {
 	implementation "io.grpc:grpc-core"
 	implementation "io.grpc:grpc-protobuf"
 	implementation "io.grpc:grpc-stub"
+	implementation "io.grpc:grpc-netty-shaded"
 
+	// https://mvnrepository.com/artifact/com.baomidou/mybatis-plus-boot-starter
+	implementation group: 'com.baomidou', name: 'mybatis-plus-boot-starter', version: '3.5.5'
+	implementation "org.reflections:reflections:0.10.2"
 
-	implementation "org.mybatis.spring.boot:mybatis-spring-boot-starter"
 	// https://mvnrepository.com/artifact/com.alibaba/druid-spring-boot-starter
 	implementation "com.alibaba:druid-spring-boot-starter"
 	runtimeOnly 'com.mysql:mysql-connector-j'

eventmesh-connectors/eventmesh-connector-dingtalk/src/main/java/org/apache/eventmesh/connector/dingtalk/config/DingDingConnectServerConfig.java

@@ -17,7 +17,7 @@
 
 package org.apache.eventmesh.connector.dingtalk.config;
 
-import org.apache.eventmesh.openconnect.api.config.Config;
+import org.apache.eventmesh.common.config.connector.Config;
 
 import lombok.Data;
 import lombok.EqualsAndHashCode;

eventmesh-connectors/eventmesh-connector-dingtalk/src/main/java/org/apache/eventmesh/connector/dingtalk/sink/connector/DingDingSinkConnector.java

@@ -17,11 +17,11 @@
 
 package org.apache.eventmesh.connector.dingtalk.sink.connector;
 
+import org.apache.eventmesh.common.config.connector.Config;
+import org.apache.eventmesh.common.config.connector.dingtalk.DingDingSinkConfig;
 import org.apache.eventmesh.common.utils.JsonUtils;
 import org.apache.eventmesh.connector.dingtalk.common.constants.ConnectRecordExtensionKeys;
 import org.apache.eventmesh.connector.dingtalk.config.DingDingMessageTemplateType;
-import org.apache.eventmesh.connector.dingtalk.sink.config.DingDingSinkConfig;
-import org.apache.eventmesh.openconnect.api.config.Config;
 import org.apache.eventmesh.openconnect.api.connector.ConnectorContext;
 import org.apache.eventmesh.openconnect.api.connector.SinkConnectorContext;
 import org.apache.eventmesh.openconnect.api.sink.Sink;

eventmesh-connectors/eventmesh-connector-dingtalk/src/test/java/org/apache/eventmesh/connector/dingtalk/sink/connector/DingDingSinkConnectorTest.java

@@ -21,12 +21,12 @@
 import static org.mockito.Mockito.times;
 import static org.mockito.Mockito.verify;
 
+import org.apache.eventmesh.common.config.connector.dingtalk.DingDingSinkConfig;
+import org.apache.eventmesh.common.remote.offset.RecordOffset;
+import org.apache.eventmesh.common.remote.offset.RecordPartition;
 import org.apache.eventmesh.connector.dingtalk.common.constants.ConnectRecordExtensionKeys;
 import org.apache.eventmesh.connector.dingtalk.config.DingDingMessageTemplateType;
-import org.apache.eventmesh.connector.dingtalk.sink.config.DingDingSinkConfig;
 import org.apache.eventmesh.openconnect.offsetmgmt.api.data.ConnectRecord;
-import org.apache.eventmesh.openconnect.offsetmgmt.api.data.RecordOffset;
-import org.apache.eventmesh.openconnect.offsetmgmt.api.data.RecordPartition;
 import org.apache.eventmesh.openconnect.util.ConfigUtil;
 
 import java.lang.reflect.Field;

eventmesh-connectors/eventmesh-connector-file/build.gradle

@@ -16,6 +16,7 @@
  */
 
 dependencies {
+    implementation project(":eventmesh-common")
     api project(":eventmesh-openconnect:eventmesh-openconnect-java")
     testImplementation('org.junit.jupiter:junit-jupiter')
     testImplementation('org.mockito:mockito-junit-jupiter')

eventmesh-connectors/eventmesh-connector-file/src/main/java/org/apache/eventmesh/connector/file/config/FileServerConfig.java

@@ -17,7 +17,7 @@
 
 package org.apache.eventmesh.connector.file.config;
 
-import org.apache.eventmesh.openconnect.api.config.Config;
+import org.apache.eventmesh.common.config.connector.Config;
 
 import lombok.Data;
 import lombok.EqualsAndHashCode;

eventmesh-connectors/eventmesh-connector-file/src/main/java/org/apache/eventmesh/connector/file/sink/connector/FileSinkConnector.java

@@ -17,8 +17,8 @@
 
 package org.apache.eventmesh.connector.file.sink.connector;
 
-import org.apache.eventmesh.connector.file.sink.config.FileSinkConfig;
-import org.apache.eventmesh.openconnect.api.config.Config;
+import org.apache.eventmesh.common.config.connector.Config;
+import org.apache.eventmesh.common.config.connector.file.FileSinkConfig;
 import org.apache.eventmesh.openconnect.api.connector.ConnectorContext;
 import org.apache.eventmesh.openconnect.api.connector.SinkConnectorContext;
 import org.apache.eventmesh.openconnect.api.sink.Sink;

eventmesh-connectors/eventmesh-connector-file/src/main/java/org/apache/eventmesh/connector/file/source/connector/FileSourceConnector.java

@@ -17,13 +17,14 @@
 
 package org.apache.eventmesh.connector.file.source.connector;
 
-import org.apache.eventmesh.connector.file.source.config.FileSourceConfig;
-import org.apache.eventmesh.openconnect.api.config.Config;
+import org.apache.eventmesh.common.config.connector.Config;
+import org.apache.eventmesh.common.config.connector.file.FileSourceConfig;
+import org.apache.eventmesh.common.remote.offset.RecordPartition;
 import org.apache.eventmesh.openconnect.api.connector.ConnectorContext;
 import org.apache.eventmesh.openconnect.api.connector.SourceConnectorContext;
 import org.apache.eventmesh.openconnect.api.source.Source;
 import org.apache.eventmesh.openconnect.offsetmgmt.api.data.ConnectRecord;
-import org.apache.eventmesh.openconnect.offsetmgmt.api.data.RecordPartition;
+import org.apache.eventmesh.common.remote.offset.file.FileRecordPartition;
 
 import java.io.BufferedReader;
 import java.io.File;
@@ -34,9 +35,7 @@
 import java.nio.file.Path;
 import java.nio.file.Paths;
 import java.util.ArrayList;
-import java.util.HashMap;
 import java.util.List;
-import java.util.Map;
 
 import lombok.extern.slf4j.Slf4j;
 
@@ -118,9 +117,10 @@ public List<ConnectRecord> poll() {
     }
 
     public static RecordPartition convertToRecordPartition(String fileName) {
-        Map<String, String> map = new HashMap<>();
-        map.put("fileName", fileName);
-        return new RecordPartition(map);
+        FileRecordPartition fileRecordPartition = new FileRecordPartition();
+        fileRecordPartition.setFileName(fileName);
+        fileRecordPartition.setClazz(fileRecordPartition.getRecordPartitionClass());
+        return fileRecordPartition;
     }
 
     private static String getFileName(String filePath) throws NullPointerException {

eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/config/HttpServerConfig.java

@@ -17,7 +17,7 @@
 
 package org.apache.eventmesh.connector.http.config;
 
-import org.apache.eventmesh.openconnect.api.config.Config;
+import org.apache.eventmesh.common.config.connector.Config;
 
 import lombok.Data;
 import lombok.EqualsAndHashCode;