public Converter getInternalValueConverter() {
        return internalValueConverter;
    }
Get the IDs of the tasks currently running in this worker.
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java