public void clearTasks() {
        log.info("Clearing {} existing task handles for connector {}", taskHandles.size(), connectorName);
        taskHandles.clear();
    }
Delete all task handles for this connector.
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectorHandle.java