protected Schema getSchema()

in timebase-kafka-connector/src/main/java/deltix/kafka/connect/RawMessageDeserializer.java [182:191]

• 10 lines of code
• 2 McCabe index (conditional complexity)

    protected Schema getSchema(RecordClassDescriptor msgType) {
        final String guid = msgType.getGuid();
        Schema valueSchema = schemaRegistry.get(guid);
        if (valueSchema == null) {
            valueSchema = buildSchema(msgType);
            schemaRegistry.put(guid, valueSchema);
            LOG.info("Built Schema for " + msgType.getName() + ": " + valueSchema);
        }
        return valueSchema;
    }