public void ensureValid()

in src/main/java/org/apache/doris/kafka/connector/cfg/DorisSinkConnectorConfig.java [311:320]

• 10 lines of code
• 4 McCabe index (conditional complexity)

        public void ensureValid(String name, Object value) {
            String s = (String) value;
            if (s != null && !s.isEmpty()) // this value is optional and can be empty
            {
                if (ConfigCheckUtils.parseTopicToTableMap(s) == null) {
                    throw new ConfigException(
                            name, value, "Format: <topic-1>:<table-1>,<topic-2>:<table-2>,...");
                }
            }
        }