private FixedUnboundEncoder getEncoder()

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

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

    private FixedUnboundEncoder getEncoder (final RecordClassDescriptor type) {
        String guid = type.getGuid();
        FixedUnboundEncoder encoder = encoders.get(guid);
        if (encoder == null) {
            encoder = InterpretingCodecMetaFactory.INSTANCE.createFixedUnboundEncoderFactory(type).create();
            encoders.put(guid, encoder);
        }
        return encoder;
    }