Merge pull request #2063 from Vip-Augus/master

[ISSUE #2062]Add type check before convert close #2062
apache · Nov 2, 2022 · 94413d7 · 94413d7
2 parents 0d5afaf + cfe94ac
commit 94413d7
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/...ne/src/main/java/org/apache/eventmesh/connector/standalone/broker/task/SubScribeTask.java b/...ne/src/main/java/org/apache/eventmesh/connector/standalone/broker/task/SubScribeTask.java
@@ -57,8 +57,9 @@ public void run() {
                 if (offset == null) {
                     CloudEvent message = standaloneBroker.getMessage(topicName);
                     if (message != null) {
-                        if (message.getExtension("offset") != null) {
-                            offset = new AtomicInteger((int) message.getExtension("offset"));
+                        Object tmpOffset = message.getExtension("offset");
+                        if (tmpOffset instanceof Integer) {
+                            offset = new AtomicInteger(Integer.parseInt(tmpOffset.toString()));
                         } else {
                             offset = new AtomicInteger(0);
                         }
@@ -113,4 +114,4 @@ public void shutdown() {
         isRunning = false;
     }
 
-}
+}