in timebase-kafka-connector/src/main/java/deltix/kafka/connect/TBSourceTask.java [108:114]
private static RecordClassDescriptor getDescriptor(RecordClassDescriptor[] descriptors, String name) {
for (RecordClassDescriptor descriptor : descriptors) {
if (name.equals(descriptor.getName()))
return descriptor;
}
return null;
}