update connector record

xwm1992 · May 20, 2024 · 6e70ae7 · 6e70ae7
1 parent c8894cf
commit 6e70ae7
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 8 deletions.
diff --git a/...gmt/api/data/canal/CanalRecordOffset.java → ...emote/offset/canal/CanalRecordOffset.java b/...gmt/api/data/canal/CanalRecordOffset.java → ...emote/offset/canal/CanalRecordOffset.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.eventmesh.openconnect.offsetmgmt.api.data.canal;
+package org.apache.eventmesh.common.remote.offset.canal;
 
 import org.apache.eventmesh.common.remote.offset.RecordOffset;
 

diff --git a/.../api/data/canal/CanalRecordPartition.java → ...te/offset/canal/CanalRecordPartition.java b/.../api/data/canal/CanalRecordPartition.java → ...te/offset/canal/CanalRecordPartition.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.eventmesh.openconnect.offsetmgmt.api.data.canal;
+package org.apache.eventmesh.common.remote.offset.canal;
 
 import org.apache.eventmesh.common.remote.offset.RecordPartition;
 

diff --git a/...i/data/rocketmq/RocketMQRecordOffset.java → ...offset/rocketmq/RocketMQRecordOffset.java b/...i/data/rocketmq/RocketMQRecordOffset.java → ...offset/rocketmq/RocketMQRecordOffset.java
@@ -15,12 +15,10 @@
  * limitations under the License.
  */
 
-package org.apache.eventmesh.openconnect.offsetmgmt.api.data.rocketmq;
+package org.apache.eventmesh.common.remote.offset.rocketmq;
 
 import org.apache.eventmesh.common.remote.offset.RecordOffset;
 
-import java.util.Map;
-
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 import lombok.ToString;

diff --git a/...ata/rocketmq/RocketMQRecordPartition.java → ...set/rocketmq/RocketMQRecordPartition.java b/...ata/rocketmq/RocketMQRecordPartition.java → ...set/rocketmq/RocketMQRecordPartition.java
@@ -15,15 +15,13 @@
  * limitations under the License.
  */
 
-package org.apache.eventmesh.openconnect.offsetmgmt.api.data.rocketmq;
+package org.apache.eventmesh.common.remote.offset.rocketmq;
 
 import org.apache.eventmesh.common.remote.offset.RecordPartition;
 
-import java.util.Map;
 import java.util.Objects;
 
 import lombok.Data;
-import lombok.EqualsAndHashCode;
 import lombok.ToString;