private void validateSchema()

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

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

    private void validateSchema(Schema schema) {
        if (instrumentField != null)
            validateSchemaField(schema, instrumentField, Schema.Type.STRING);
        if (symbolField != null)
            validateSchemaField(schema, symbolField, Schema.Type.STRING);
        if (timeField != null)
            validateSchemaField(schema, timeField, Schema.Type.INT64);

        // verify referenced source fields exist in the schema
        validateSourceFields(schema, fieldSelection.getExcludedFields());
        validateSourceFields(schema, fieldSelection.getIncludedFields());
        validateSourceFields(schema, fieldMap.getSourceFields());

        // check for conflicts with new TB fields
        validateNewFields(schema, tbOffsetField, tbKeyField, tbTombstoneField);
    }