public boolean isSinkConnector(String connName) {
        WorkerConnector workerConnector = connectors.get(connName);
        if (workerConnector == null)
            throw new ConnectException("Connector " + connName + " not found in this worker.");

        try (LoaderSwap loaderSwap = plugins.withClassLoader(workerConnector.loader())) {
            return workerConnector.isSinkConnector();
        }
    }
Return true if the connector associated with this worker is a sink connector.

@param connName the connector name.
@return true if the connector belongs to the worker and is a sink connector.
@throws ConnectException if the worker does not manage a connector with the given name.
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java