@Override
    public boolean contains(String connector) {
        synchronized (lock) {
            return connectorConfigs.containsKey(connector);
        }
    }
Get a snapshot of the current state of the cluster.
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaConfigBackingStore.java