@Override
    public synchronized void removeTaskConfigs(String connector) {
        ConnectorState state = connectors.get(connector);
        if (state == null)
            throw new IllegalArgumentException("Cannot remove tasks for non-existing connector");

        HashSet<ConnectorTaskId> taskIds = new HashSet<>(state.taskConfigs.keySet());
        state.taskConfigs.clear();
        state.appliedConnConfig = null;

        if (updateListener != null)
            updateListener.onTaskConfigUpdate(taskIds);
    }
An implementation of ConfigBackingStore that stores Kafka Connect connector configurations in-memory (i.e. configs
aren't persisted and will be wiped if the worker is restarted).
connect/runtime/src/main/java/org/apache/kafka/connect/storage/MemoryConfigBackingStore.java