diff --git a/distributedlog-core/src/main/java/org/apache/distributedlog/util/DLUtils.java b/distributedlog-core/src/main/java/org/apache/distributedlog/util/DLUtils.java index 833c9f31b..a0083b244 100644 --- a/distributedlog-core/src/main/java/org/apache/distributedlog/util/DLUtils.java +++ b/distributedlog-core/src/main/java/org/apache/distributedlog/util/DLUtils.java @@ -279,7 +279,7 @@ public static String normalizeClientId(String clientId) { * @return true if it is reserved name, otherwise false. */ public static boolean isReservedStreamName(String name) { - return name.startsWith("."); + return name.startsWith(".") || name.startsWith("<"); } /**