diff --git a/paimon-common/src/main/java/org/apache/paimon/CoreOptions.java b/paimon-common/src/main/java/org/apache/paimon/CoreOptions.java
index 3c1bdf6fda4d..ecef7a9cbe9c 100644
--- a/paimon-common/src/main/java/org/apache/paimon/CoreOptions.java
+++ b/paimon-common/src/main/java/org/apache/paimon/CoreOptions.java
@@ -1922,14 +1922,10 @@ public String partitionTimestampPattern() {
         return options.get(PARTITION_TIMESTAMP_PATTERN);
     }
 
-    public int readBatchSize() {
-        return options.get(READ_BATCH_SIZE);
-    }
-
     public String consumerId() {
         String consumerId = options.get(CONSUMER_ID);
-        if (StringUtils.isBlankString(consumerId)) {
-            throw new RuntimeException("consumer id cannot be blank string");
+        if (consumerId != null && consumerId.isEmpty()) {
+            throw new RuntimeException("consumer id cannot be empty string.");
         }
         return consumerId;
     }
diff --git a/paimon-common/src/main/java/org/apache/paimon/utils/StringUtils.java b/paimon-common/src/main/java/org/apache/paimon/utils/StringUtils.java
index 7b4bce9be8c7..3dbc9779e7df 100644
--- a/paimon-common/src/main/java/org/apache/paimon/utils/StringUtils.java
+++ b/paimon-common/src/main/java/org/apache/paimon/utils/StringUtils.java
@@ -551,13 +551,6 @@ public static boolean isBlank(String str) {
         return true;
     }
 
-    public static boolean isBlankString(String str) {
-        if (str != null && str.length() == 0) {
-            return true;
-        }
-        return false;
-    }
-
     public static String quote(String str) {
         return "`" + str + "`";
     }