private List<ErrorReporter<SourceRecord>> sourceTaskReporters(ConnectorTaskId id, ConnectorConfig connConfig,
                                                       ErrorHandlingMetrics errorHandlingMetrics) {
        List<ErrorReporter<SourceRecord>> reporters = new ArrayList<>();
        LogReporter<SourceRecord> logReporter = new LogReporter.Source(id, connConfig, errorHandlingMetrics);
        reporters.add(logReporter);

        return reporters;
    }
@return the {@link ProducerConfig#TRANSACTIONAL_ID_CONFIG transactional ID} to use for a task that writes
records and/or offsets in a transaction. Not to be confused with {@link DistributedConfig#transactionalProducerId()},
which is not used by tasks at all, but instead, by the worker itself.
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java