public static TopicContainerMap deserialize()

in src/main/java/com/azure/cosmos/kafka/connect/TopicContainerMap.java [28:48]

• 19 lines of code
• 3 McCabe index (conditional complexity)

    public static TopicContainerMap deserialize(String input) {
        if (StringUtils.isEmpty(input)) {
            return TopicContainerMap.empty();
        }

        if (StringUtils.contains(input, '#')) { // There's at least one pair
            String[] items = StringUtils.split(input, ',');
            Stream<String[]> keyValuePairs = Arrays.stream(items).map(item -> {
                String[] pair = StringUtils.split(item, '#');
                pair[0] = StringUtils.trimToNull(pair[0]);
                pair[1] = StringUtils.trimToNull(pair[1]);
                return pair;
            });

            BidiMap<String, String> map = new DualHashBidiMap<>();
            keyValuePairs.forEach(pair -> map.put(pair[0], pair[1]));
            return new TopicContainerMap(map);
        } else {
            throw new IllegalArgumentException("Invalid topic container map.");
        }
    }