in timebase-kafka-connector/src/main/java/deltix/kafka/connect/RawMessageSerializer.java [409:415]
private RecordClassDescriptor buildFieldDescriptor(Schema schema) {
List<DataField> fields = new ArrayList<>();
for (Field field : schema.fields()) {
addDataField(field.name(), field.schema(), fields, false);
}
return new RecordClassDescriptor(schema.name(), schema.name(), schema.doc(), false, null, fields.toArray(new DataField[0]));
}