[rocketmq-connect] branch master updated: [ISSUE #53] update connect api to 0.1.2

[dinglei]

This is an automated email from the ASF dual-hosted git repository.

dinglei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git


The following commit(s) were added to refs/heads/master by this push:
     new dcf52f2  [ISSUE #53] update connect api to 0.1.2
dcf52f2 is described below

commit dcf52f29aaac0cbf9b1079d4e41855fbf82c0b68
Author: zhoubo <877036...@qq.com>
AuthorDate: Mon Apr 11 15:18:11 2022 +0800

    [ISSUE #53] update connect api to 0.1.2
    
    [ISSUE #53] update connect api to 0.1.2
---
 pom.xml                                                               | 2 +-
 .../rocketmq/connect/runtime/store/PositionStorageReaderImpl.java     | 4 ++--
 .../runtime/connectorwrapper/testimpl/TestPositionStorageReader.java  | 4 ++--
 3 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/pom.xml b/pom.xml
index 124a37d..bcd637d 100644
--- a/pom.xml
+++ b/pom.xml
@@ -42,7 +42,7 @@
         <assertj.version>2.6.0</assertj.version>
         <mockito.version>3.2.4</mockito.version>
         <httpclient.version>4.5.5</httpclient.version>
-        
<openmessaging.connector.version>0.1.2-SNAPSHOT</openmessaging.connector.version>
+        
<openmessaging.connector.version>0.1.2</openmessaging.connector.version>
         <fastjson.version>1.2.80</fastjson.version>
         <javalin.version>2.8.0</javalin.version>
         <slf4j.version>1.7.7</slf4j.version>
diff --git 
a/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store/PositionStorageReaderImpl.java
 
b/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store/PositionStorageReaderImpl.java
index a156f6b..84c5365 100644
--- 
a/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store/PositionStorageReaderImpl.java
+++ 
b/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store/PositionStorageReaderImpl.java
@@ -35,11 +35,11 @@ public class PositionStorageReaderImpl implements 
OffsetStorageReader {
         this.positionManagementService = positionManagementService;
     }
 
-    @Override public <T> RecordOffset readOffset(RecordPartition partition) {
+    @Override public RecordOffset readOffset(RecordPartition partition) {
         return positionManagementService.getPositionTable().get(partition);
     }
 
-    @Override public <T> Map<RecordPartition, RecordOffset> 
readOffsets(Collection<RecordPartition> partitions) {
+    @Override public  Map<RecordPartition, RecordOffset> 
readOffsets(Collection<RecordPartition> partitions) {
         Map<RecordPartition, RecordOffset> result = new HashMap<>();
         Map<RecordPartition, RecordOffset> allData = 
positionManagementService.getPositionTable();
         for (RecordPartition key : partitions) {
diff --git 
a/rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestPositionStorageReader.java
 
b/rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestPositionStorageReader.java
index 242f833..a35f28f 100644
--- 
a/rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestPositionStorageReader.java
+++ 
b/rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestPositionStorageReader.java
@@ -25,11 +25,11 @@ import java.util.Map;
 
 public class TestPositionStorageReader implements OffsetStorageReader {
 
-    @Override public <T> RecordOffset readOffset(RecordPartition partition) {
+    @Override public RecordOffset readOffset(RecordPartition partition) {
         return null;
     }
 
-    @Override public <T> Map<RecordPartition, RecordOffset> 
readOffsets(Collection<RecordPartition> partitions) {
+    @Override public Map<RecordPartition, RecordOffset> 
readOffsets(Collection<RecordPartition> partitions) {
         return null;
     }
 }