@Override
    public void initialize(TaskConfig taskConfig) {
        try {
            this.taskConfig = taskConfig.originalsStrings();
            this.context = new WorkerSinkTaskContext(consumer, this, configState);
        } catch (Throwable t) {
            log.error("{} Task failed initialization and will not be started.", this, t);
            onFailure(t);
        }
    }
{@link WorkerTask} that uses a {@link SinkTask} to export data from Kafka.
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java