fix ci not pass

Author: mxsm

eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/JdbcSourceConnector.java

@@ -32,7 +32,8 @@
 import org.apache.eventmesh.openconnect.api.config.Config;
 import org.apache.eventmesh.openconnect.api.config.SourceConfig;
 import org.apache.eventmesh.openconnect.api.connector.SourceConnector;
-import org.apache.eventmesh.openconnect.api.data.ConnectRecord;
+import org.apache.eventmesh.openconnect.offsetmgmt.api.data.ConnectRecord;
+
 
 import org.apache.commons.collections4.CollectionUtils;
 

eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/TaskManagerCoordinator.java

@@ -18,7 +18,9 @@
 
 package org.apache.eventmesh.connector.jdbc.source;
 
-import org.apache.eventmesh.openconnect.api.data.ConnectRecord;
+
+
+import org.apache.eventmesh.openconnect.offsetmgmt.api.data.ConnectRecord;
 
 import org.apache.commons.collections4.CollectionUtils;
 

eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/TaskManagerListener.java

@@ -17,7 +17,7 @@
 
 package org.apache.eventmesh.connector.jdbc.source;
 
-import org.apache.eventmesh.openconnect.api.data.ConnectRecord;
+import org.apache.eventmesh.openconnect.offsetmgmt.api.data.ConnectRecord;
 
 import java.util.List;
 

eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/cdc/CdcTaskManager.java

@@ -28,9 +28,10 @@
 import org.apache.eventmesh.connector.jdbc.table.catalog.TableId;
 import org.apache.eventmesh.connector.jdbc.table.type.EventMeshRow;
 import org.apache.eventmesh.connector.jdbc.table.type.RowHandleMode;
-import org.apache.eventmesh.openconnect.api.data.ConnectRecord;
-import org.apache.eventmesh.openconnect.api.data.RecordOffset;
-import org.apache.eventmesh.openconnect.api.data.RecordPartition;
+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.commons.collections4.CollectionUtils;
 

eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/snapshot/SnapshotTaskManager.java

@@ -27,8 +27,9 @@
 import org.apache.eventmesh.connector.jdbc.source.dialect.cdc.CdcTaskSelectStrategy;
 import org.apache.eventmesh.connector.jdbc.source.dialect.cdc.RandomCdcTaskSelectStrategy;
 import org.apache.eventmesh.connector.jdbc.table.catalog.TableId;
-import org.apache.eventmesh.openconnect.api.data.ConnectRecord;
-import org.apache.eventmesh.openconnect.api.data.RecordPartition;
+import org.apache.eventmesh.openconnect.offsetmgmt.api.data.ConnectRecord;
+import org.apache.eventmesh.openconnect.offsetmgmt.api.data.RecordPartition;
+
 
 import org.apache.commons.collections4.CollectionUtils;
 

eventmesh-spi/src/main/java/org/apache/eventmesh/spi/EventMeshExtensionType.java

@@ -30,6 +30,7 @@ public enum EventMeshExtensionType {
     METRICS("metrics"),
     TRACE("trace"),
     JDBC_CDC_ENGINE("jdbc_cdc_engine"),
+    JDBC_SNAPSHOT_ENGINE("jdbc_snapshot_engine"),
     JDBC_DATABASE_DIALECT("jdbc_database_dialect"),
     OFFSETMGMT("offsetMgmt"),
     ;