public void set()

in src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQConfigBuilder.java [87:104]

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

    public void set(Configuration config) {
        Map<String, String> existedConfigs = configuration.toMap();
        List<String> duplicatedKeys = new ArrayList<>();
        for (Map.Entry<String, String> entry : config.toMap().entrySet()) {
            String key = entry.getKey();
            if (existedConfigs.containsKey(key)) {
                String value2 = existedConfigs.get(key);
                if (!Objects.equals(value2, entry.getValue())) {
                    duplicatedKeys.add(key);
                }
            }
        }
        checkArgument(
                duplicatedKeys.isEmpty(),
                "Invalid configuration, these keys %s are already exist with different config value.",
                duplicatedKeys);
        configuration.addAll(config);
    }