private void validateSourceFields()

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

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

    private void validateSourceFields(Schema schema, Set<String> srcFields) {
        if (srcFields != null && !srcFields.isEmpty()) {
            for (String srcField : srcFields) {
                String destField = fieldMap.getDestination(srcField);
                String[] srcPath = fieldMap.getSourcePath(destField);
                if (getField(schema, srcPath) == null) {
                    throw new IllegalArgumentException("Schema is missing specified field: " + srcField);
                }
            }
        }
    }