in src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/KustoSinkConfig.java [125:137]
public static ConfigDef getConfig() {
try {
String tempDirectory = System.getProperty("java.io.tmpdir");
ConfigDef result = new ConfigDef();
defineConnectionConfigs(result);
defineWriteConfigs(result, tempDirectory);
defineErrorHandlingAndRetriesConfigs(result);
return result;
} catch (Exception ex) {
log.error("Error in initializing config", ex);
throw new RuntimeException("Error initializing config. Exception ", ex);
}
}