private static void validateSchemaField()

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

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

    private static void validateSchemaField(Schema schema, String fieldName, Schema.Type fieldType) {
        Field field = schema.field(fieldName);
        if (field == null) {
            throw new IllegalArgumentException("Schema has no field " + fieldName);
        }
        if (fieldType != null && field.schema().type() != fieldType) {
            throw new IllegalArgumentException("Field " + fieldName + " must be a " + fieldType);
        }
    }