in src/main/java/com/azure/cosmos/kafka/connect/source/CosmosDBSourceConfig.java [111:160]
private static void defineTaskConfigs(ConfigDef result) {
final String taskGroupName = "Task Parameters";
int taskGroupOrder = 0;
result
.define(
COSMOS_SOURCE_TASK_TIMEOUT_CONF,
Type.LONG,
COSMOS_SOURCE_TASK_TIMEOUT_DEFAULT,
Importance.MEDIUM,
COSMOS_SOURCE_TASK_TIMEOUT_DOC,
taskGroupName,
taskGroupOrder++,
Width.SHORT,
COSMOS_SOURCE_TASK_TIMEOUT_DISPLAY
)
.define(
COSMOS_SOURCE_TASK_BUFFER_SIZE_CONF,
Type.LONG,
COSMOS_SOURCE_TASK_BUFFER_SIZE_DEFAULT,
Importance.MEDIUM,
COSMOS_SOURCE_TASK_BUFFER_SIZE_DOC,
taskGroupName,
taskGroupOrder++,
Width.SHORT,
COSMOS_SOURCE_TASK_BUFFER_SIZE_DISPLAY
)
.define(
COSMOS_SOURCE_TASK_BATCH_SIZE_CONF,
Type.LONG,
COSMOS_SOURCE_TASK_BATCH_SIZE_DEFAULT,
Importance.MEDIUM,
COSMOS_SOURCE_TASK_BATCH_SIZE_DOC,
taskGroupName,
taskGroupOrder++,
Width.SHORT,
COSMOS_SOURCE_TASK_BATCH_SIZE_DISPLAY
)
.define(
COSMOS_SOURCE_TASK_POLL_INTERVAL_CONF,
Type.LONG,
COSMOS_SOURCE_TASK_POLL_INTERVAL_DEFAULT,
Importance.MEDIUM,
COSMOS_SOURCE_TASK_POLL_INTERVAL_DOC,
taskGroupName,
taskGroupOrder++,
Width.SHORT,
COSMOS_SOURCE_TASK_POLL_INTERVAL_DISPLAY
);
}