in src/main/java/com/azure/cosmos/kafka/connect/CosmosDBConfig.java [71:105]
private static void defineConnectionConfigs(ConfigDef result) {
final String connectionGroupName = "Connection";
int connectionGroupOrder = 0;
result
.define(
COSMOS_CONN_ENDPOINT_CONF,
Type.STRING,
ConfigDef.NO_DEFAULT_VALUE,
NON_EMPTY_STRING,
Importance.HIGH,
COSMOS_CONN_ENDPOINT_DOC,
connectionGroupName,
connectionGroupOrder++,
Width.LONG,
COSMOS_CONN_ENDPOINT_DISPLAY
)
.define(
COSMOS_CONN_KEY_CONF,
Type.PASSWORD,
ConfigDef.NO_DEFAULT_VALUE,
Importance.HIGH,
COSMOS_CONN_KEY_DOC,
connectionGroupName,
connectionGroupOrder++,
Width.LONG,
COSMOS_CONN_KEY_DISPLAY
)
.defineInternal(
COSMOS_PROVIDER_NAME_CONF,
Type.STRING,
COSMOS_PROVIDER_NAME_DEFAULT,
Importance.LOW
);
}