private void validateNewFields()

in timebase-kafka-connector/src/main/java/deltix/kafka/connect/RawMessageSerializer.java [446:459]

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

    private void validateNewFields(Schema schema, String... newFields) {
        for (int i = 0; i < newFields.length; i++) {
            String newField = newFields[i];
            if (newField != null) {
                validateNewField(schema, newField);

                //search for duplicates
                for (int j = i+1; j < newFields.length; j++) {
                    if (newField.equals(newFields[j]))
                        throw new IllegalArgumentException("\"" + newField + "\" name is configured for multiple fields");
                }
            }
        }
    }