in src/main/java/com/azure/cosmos/kafka/connect/sink/id/strategy/TemplateStrategy.java [52:66]
private String resolveAll(String template, SinkRecord record) {
int lastIndex = 0;
StringBuilder output = new StringBuilder();
Matcher matcher = PATTERN.matcher(template);
while (matcher.find()) {
output.append(template, lastIndex, matcher.start())
.append(METHODS_BY_VARIABLE.get(matcher.group(1)).apply(record));
lastIndex = matcher.end();
}
if (lastIndex < template.length()) {
output.append(template, lastIndex, template.length());
}
return output.toString();
}