fixed

apache · Mar 8, 2023 · 17d572b · 17d572b
1 parent 54fda9b
commit 17d572b
Show file tree

Hide file tree

Showing 5 changed files with 4 additions and 11 deletions.
diff --git a/connectors/rocketmq-connect-cassandra/pom.xml b/connectors/rocketmq-connect-cassandra/pom.xml
@@ -38,7 +38,7 @@
         <!-- Compiler settings properties -->
         <maven.compiler.source>1.8</maven.compiler.source>
         <maven.compiler.target>1.8</maven.compiler.target>
-        <rocketmq.version>4.5.2</rocketmq.version>
+        <rocketmq.version>4.9.4</rocketmq.version>
     </properties>
 
     <build>

diff --git a/connectors/rocketmq-connect-deltalake/pom.xml b/connectors/rocketmq-connect-deltalake/pom.xml
@@ -15,7 +15,7 @@
         <!-- Compiler settings properties -->
         <maven.compiler.source>1.8</maven.compiler.source>
         <maven.compiler.target>1.8</maven.compiler.target>
-        <rocketmq.version>4.5.2</rocketmq.version>
+        <rocketmq.version>4.9.4</rocketmq.version>
         <avro.version>1.10.2</avro.version>
         <parquet.version>1.10.1</parquet.version>
         <scala.version>2.12</scala.version>

diff --git a/connectors/rocketmq-connect-redis/pom.xml b/connectors/rocketmq-connect-redis/pom.xml
@@ -16,7 +16,7 @@
         <!-- Compiler settings properties -->
         <maven.compiler.source>1.8</maven.compiler.source>
         <maven.compiler.target>1.8</maven.compiler.target>
-        <rocketmq.version>4.5.2</rocketmq.version>
+        <rocketmq.version>4.9.4</rocketmq.version>
     </properties>
 
     <build>

diff --git a/...onnect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config/WorkerConfig.java b/...onnect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config/WorkerConfig.java
@@ -17,15 +17,10 @@
 
 package org.apache.rocketmq.connect.runtime.config;
 
-import org.apache.rocketmq.common.MixAll;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
 import java.io.File;
 import java.util.HashMap;
 import java.util.Map;
-
-import static org.apache.rocketmq.connect.runtime.common.LoggerName.ROCKETMQ_RUNTIME;
+import org.apache.rocketmq.common.MixAll;
 
 /**
  * Configurations for runtime.
@@ -34,7 +29,6 @@ public class WorkerConfig {
     public static final String METRIC_CLASS = "metrics.reporter";
     public static final String CONNECT_HOME_PROPERTY = "connect.home.dir";
     public static final String CONNECT_HOME_ENV = "CONNECT_HOME";
-    private static final Logger log = LoggerFactory.getLogger(ROCKETMQ_RUNTIME);
     private String connectHome = System.getProperty(CONNECT_HOME_PROPERTY, System.getenv(CONNECT_HOME_ENV));
 
     /**

diff --git a/...-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/ConnectUtil.java b/...-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/ConnectUtil.java
@@ -559,7 +559,6 @@ private static ConsumeStats overrideExamineConsumeStats(DefaultMQAdminExt adminE
         if (staticResult.getOffsetTable().isEmpty()) {
             throw new MQClientException(ResponseCode.CONSUMER_NOT_ONLINE, "Not found the consumer group consume stats, because return offset table is empty, maybe the consumer not consume any message");
         }
-
         return staticResult;
     }
-Original file line number
+Diff line change
@@ Expand Up @@
             if (staticResult.getOffsetTable().isEmpty()) {
                 throw new MQClientException(ResponseCode.CONSUMER_NOT_ONLINE, "Not found the consumer group consume stats, because return offset table is empty, maybe the consumer not consume any message");
             }
             return staticResult;
         }
@@ Expand Down @@