private boolean skipWatermarkKey()

in core/src/main/java/org/apache/rocketmq/streams/core/state/RocksDBStore.java [178:190]

• 11 lines of code
• 5 McCabe index (conditional complexity)

    private boolean skipWatermarkKey(byte[] target) {
        if (target == null || target.length == 0) {
            return false;
        }

        try {
            String key = new String(target, StandardCharsets.UTF_8);

            return !StringUtils.isBlank(key) && key.startsWith(Constant.WATERMARK_KEY);
        } catch (Throwable ignored) {
            return false;
        }
    }