in src/main/java/com/azure/cosmos/kafka/connect/sink/CosmosDBSinkConfig.java [71:80]
private IdStrategy createIdStrategy() {
IdStrategy idStrategy;
try {
idStrategy = (IdStrategy) getClass(ID_STRATEGY_CONFIG).getConstructor().newInstance();
} catch (Exception e) {
throw new ConfigException("Could not instantiate IdStrategy", e);
}
idStrategy.configure(this.originalsWithPrefix(AbstractIdStrategyConfig.PREFIX));
return idStrategy;
}