in src/main/java/com/azure/cosmos/kafka/connect/source/CosmosDBSourceConfig.java [180:208]
private static void defineMessageConfigs(ConfigDef result) {
final String messageGroupName = "Message Key";
int messageGroupOrder = 0;
result
.define(
COSMOS_MESSAGE_KEY_ENABLED_CONF,
Type.BOOLEAN,
COSMOS_MESSAGE_KEY_ENABLED_DEFAULT,
Importance.MEDIUM,
COSMOS_MESSAGE_KEY_ENABLED_DOC,
messageGroupName,
messageGroupOrder++,
Width.SHORT,
COSMOS_MESSAGE_KEY_ENABLED_DISPLAY
)
.define(
COSMOS_MESSAGE_KEY_FIELD_CONF,
Type.STRING,
COSMOS_MESSAGE_KEY_FIELD_DEFAULT,
Importance.MEDIUM,
COSMOS_MESSAGE_KEY_FIELD_DOC,
messageGroupName,
messageGroupOrder++,
Width.SHORT,
COSMOS_MESSAGE_KEY_FIELD_DISPLAY,
Arrays.asList(COSMOS_MESSAGE_KEY_ENABLED_CONF)
);
}