in timebase-kafka-connector/src/main/java/deltix/kafka/connect/FieldMap.java [14:26]
public FieldMap(String names, char pathSeparator) {
this.pathSeparator = pathSeparator;
if (names != null && !names.trim().isEmpty()) {
for (String namePair : names.split(",")) {
String[] aliases = namePair.trim().split(":");
if (aliases.length != 2) {
throw new IllegalArgumentException("Invalid field mapping format: " + names);
}
addAlias(aliases[0], aliases[1]);
}
}
}