fixed

apache · Apr 13, 2023 · 88b1810 · 88b1810
1 parent 9ce6621
commit 88b1810
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...ain/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/common/RocketMqAdminUtil.java b/...ain/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/common/RocketMqAdminUtil.java
@@ -59,8 +59,7 @@
 
 /** Tools for creating RocketMq topic and group. */
 public class RocketMqAdminUtil {
-    private static final long GET_ALL_GROUP = 3000L;
-
+
     public static String createUniqInstance(String prefix) {
         return prefix.concat("-").concat(UUID.randomUUID().toString());
     }