in src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/KustoSinkConfig.java [201:248]
private static void defineWriteConfigs(ConfigDef result, String tempDirectory) {
final String writeGroupName = "Writes";
int writeGroupOrder = 0;
result
.define(
KUSTO_TABLES_MAPPING_CONF,
Type.STRING,
ConfigDef.NO_DEFAULT_VALUE,
Importance.HIGH,
KUSTO_TABLES_MAPPING_DOC,
writeGroupName,
writeGroupOrder++,
Width.MEDIUM,
KUSTO_TABLES_MAPPING_DISPLAY)
.define(
KUSTO_SINK_TEMP_DIR_CONF,
Type.STRING,
tempDirectory,
Importance.LOW,
KUSTO_SINK_TEMP_DIR_DOC,
writeGroupName,
writeGroupOrder++,
Width.MEDIUM,
KUSTO_SINK_TEMP_DIR_DISPLAY)
.define(
KUSTO_SINK_FLUSH_SIZE_BYTES_CONF,
Type.LONG,
FileUtils.ONE_MB,
ConfigDef.Range.atLeast(100),
Importance.MEDIUM,
KUSTO_SINK_FLUSH_SIZE_BYTES_DOC,
writeGroupName,
writeGroupOrder++,
Width.MEDIUM,
KUSTO_SINK_FLUSH_SIZE_BYTES_DISPLAY)
.define(
KUSTO_SINK_FLUSH_INTERVAL_MS_CONF,
Type.LONG,
TimeUnit.SECONDS.toMillis(30),
ConfigDef.Range.atLeast(100),
Importance.HIGH,
KUSTO_SINK_FLUSH_INTERVAL_MS_DOC,
writeGroupName,
writeGroupOrder++,
Width.MEDIUM,
KUSTO_SINK_FLUSH_INTERVAL_MS_DISPLAY);
}