From 17d572bc08e111ccbd75d1c85676aa811934a23e Mon Sep 17 00:00:00 2001
From: sunxiaojian <sunxiaojian926@163.com>
Date: Wed, 8 Mar 2023 11:44:10 +0800
Subject: [PATCH] fixed

---
 connectors/rocketmq-connect-cassandra/pom.xml             | 2 +-
 connectors/rocketmq-connect-deltalake/pom.xml             | 2 +-
 connectors/rocketmq-connect-redis/pom.xml                 | 2 +-
 .../rocketmq/connect/runtime/config/WorkerConfig.java     | 8 +-------
 .../rocketmq/connect/runtime/utils/ConnectUtil.java       | 1 -
 5 files changed, 4 insertions(+), 11 deletions(-)

diff --git a/connectors/rocketmq-connect-cassandra/pom.xml b/connectors/rocketmq-connect-cassandra/pom.xml
index 4071ab7f6..c3c018f52 100644
--- 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
index 1333c343b..6d96412c5 100644
--- 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
index 73e3db969..4bd556a68 100644
--- 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/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config/WorkerConfig.java b/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config/WorkerConfig.java
index 1a0ee17eb..a29152dfb 100644
--- a/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config/WorkerConfig.java
+++ b/rocketmq-connect-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/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/ConnectUtil.java b/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/ConnectUtil.java
index e5321fe3f..158d6ada4 100644
--- a/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/ConnectUtil.java
+++ b/rocketmq-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;
     }