in timebase-kafka-connector/src/main/java/deltix/kafka/connect/FieldMap.java [28:44]
public void addAlias(String srcField, String destField) {
// validate and normalize parameters by removing any spaces
String[] srcPath = splitPath(srcField);
srcField = makePathString(srcPath);
destField = destField.trim();
if (srcField.isEmpty() || destField.isEmpty() || srcField.equals(destField)) {
throw new IllegalArgumentException("Invalid field mapping: \"" + srcField + "\" -> \"" + destField + "\"");
}
if (forward.put(srcField, destField) != null) {
throw new IllegalArgumentException("Source fields names must be unique");
}
if (backward.put(destField, srcField) != null) {
throw new IllegalArgumentException("Destination fields names must be unique");
}
sourcePaths.put(destField, srcPath);
}