@Override
    protected void recordDispatched(SourceRecord record) {
        // No-op
    }
{@link WorkerTask} that uses a {@link SourceTask} to ingest data into Kafka.
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java