in src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/KustoSinkConfig.java [250:363]
private static void defineConnectionConfigs(ConfigDef result) {
final String connectionGroupName = "Connection";
int connectionGroupOrder = 0;
result
.define(
KUSTO_INGEST_URL_CONF,
Type.STRING,
ConfigDef.NO_DEFAULT_VALUE,
Importance.HIGH,
KUSTO_INGEST_URL_DOC,
connectionGroupName,
connectionGroupOrder++,
Width.MEDIUM,
KUSTO_INGEST_URL_DISPLAY)
.define(
KUSTO_ENGINE_URL_CONF,
Type.STRING,
ConfigDef.NO_DEFAULT_VALUE,
Importance.LOW,
KUSTO_ENGINE_URL_DOC,
connectionGroupName,
connectionGroupOrder++,
Width.MEDIUM,
KUSTO_ENGINE_URL_DISPLAY)
.define(
KUSTO_AUTH_APPKEY_CONF,
Type.PASSWORD,
null,
Importance.HIGH,
KUSTO_AUTH_APPKEY_DOC,
connectionGroupName,
connectionGroupOrder++,
Width.MEDIUM,
KUSTO_AUTH_APPKEY_DISPLAY)
.define(
KUSTO_AUTH_ACCESS_TOKEN_CONF,
Type.PASSWORD,
null,
Importance.LOW,
KUSTO_AUTH_ACCESS_TOKEN_DOC,
connectionGroupName,
connectionGroupOrder++,
Width.MEDIUM,
KUSTO_AUTH_ACCESS_TOKEN_DISPLAY)
.define(
KUSTO_AUTH_APPID_CONF,
Type.STRING,
null,
Importance.HIGH,
KUSTO_AUTH_APPID_DOC,
connectionGroupName,
connectionGroupOrder++,
Width.MEDIUM,
KUSTO_AUTH_APPID_DISPLAY)
.define(
KUSTO_AUTH_AUTHORITY_CONF,
Type.STRING,
null,
Importance.HIGH,
KUSTO_AUTH_AUTHORITY_DOC,
connectionGroupName,
connectionGroupOrder++,
Width.MEDIUM,
KUSTO_AUTH_AUTHORITY_DISPLAY)
.define(
KUSTO_SINK_ENABLE_TABLE_VALIDATION,
Type.BOOLEAN,
Boolean.FALSE,
Importance.LOW,
KUSTO_SINK_ENABLE_TABLE_VALIDATION_DOC,
connectionGroupName,
connectionGroupOrder++,
Width.SHORT,
KUSTO_SINK_ENABLE_TABLE_VALIDATION_DISPLAY)
.define(
KUSTO_AUTH_STRATEGY_CONF,
Type.STRING,
KustoAuthenticationStrategy.APPLICATION.name(),
ConfigDef.ValidString.in(
KustoAuthenticationStrategy.APPLICATION.name(),
KustoAuthenticationStrategy.APPLICATION.name().toLowerCase(Locale.ENGLISH),
KustoAuthenticationStrategy.MANAGED_IDENTITY.name(),
KustoAuthenticationStrategy.MANAGED_IDENTITY.name().toLowerCase(Locale.ENGLISH),
KustoAuthenticationStrategy.AZ_DEV_TOKEN.name(),
KustoAuthenticationStrategy.AZ_DEV_TOKEN.name().toLowerCase(Locale.ENGLISH),
KustoAuthenticationStrategy.WORKLOAD_IDENTITY.name(),
KustoAuthenticationStrategy.WORKLOAD_IDENTITY.name().toLowerCase(Locale.ENGLISH)),
Importance.HIGH,
KUSTO_AUTH_STRATEGY_DOC,
connectionGroupName,
connectionGroupOrder++,
Width.MEDIUM,
KUSTO_AUTH_STRATEGY_DISPLAY)
.define(
KUSTO_CONNECTION_PROXY_HOST,
Type.STRING,
null,
Importance.LOW,
KUSTO_CONNECTION_PROXY_HOST_DOC,
connectionGroupName,
connectionGroupOrder++,
Width.MEDIUM,
KUSTO_CONNECTION_PROXY_HOST_DISPLAY)
.define(
KUSTO_CONNECTION_PROXY_PORT,
Type.INT,
-1,
Importance.LOW,
KUSTO_CONNECTION_PROXY_PORT_DOC,
connectionGroupName,
connectionGroupOrder++,
Width.MEDIUM,
KUSTO_CONNECTION_PROXY_PORT_DISPLAY);
}