@Override
    public void execute() {
        log.info("{} Executing sink task", this);
        // Make sure any uncommitted data has been committed and the task has
        // a chance to clean up its state
        try (UncheckedCloseable suppressible = this::closeAllPartitions) {
            while (!isStopping())
                iteration();
        } catch (WakeupException e) {
            log.trace("Consumer woken up during initial offset commit attempt, " 
                + "but succeeded during a later attempt");
        }
    }
{@link WorkerTask} that uses a {@link SinkTask} to export data from Kafka.
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java