public boolean startExactlyOnceSourceTask(
            ConnectorTaskId id,
            ClusterConfigState configState,
            Map<String, String> connProps,
            Map<String, String> taskProps,
            TaskStatus.Listener statusListener,
            TargetState initialState,
            Runnable preProducerCheck,
            Runnable postProducerCheck
    ) {
        return startTask(id, connProps, taskProps, configState, statusListener,
                new ExactlyOnceSourceTaskBuilder(id, configState, statusListener, initialState, preProducerCheck, postProducerCheck));
    }
Start a source task with exactly-once support managed by this worker.

@param id                the task ID.
@param configState       the most recent {@link ClusterConfigState} known to the worker
@param connProps         the connector properties.
@param taskProps         the tasks properties.
@param statusListener    a listener for the runtime status transitions of the task.
@param initialState      the initial state of the connector.
@param preProducerCheck  a preflight check that should be performed before the task initializes its transactional producer.
@param postProducerCheck a preflight check that should be performed after the task initializes its transactional producer,
                         but before producing any source records or offsets.
@return true if the task started successfully.
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java