private void initSerializer()

in timebase-kafka-connector/src/main/java/deltix/kafka/connect/TBSinkTask.java [112:122]

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

    private void initSerializer(SinkRecord record) {
        assert serializer == null;

        RecordClassDescriptor descriptor = null;
        if (msgStream != null) {
            descriptor = msgStream.getFixedType();
            if (descriptor == null)
                throw new IllegalArgumentException("TimeBase message stream \"" + config.getTBStream() + "\" does not have fixed type");
        }
        serializer = new RawMessageSerializer(config, descriptor, record.valueSchema());
    }