in timebase-kafka-connector/src/main/java/deltix/kafka/connect/TBSinkTask.java [112:122]
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());
}