@Override
    public synchronized void putTaskConfigs(String connector, List<Map<String, String>> configs) {
        ConnectorState state = connectors.get(connector);
        if (state == null)
            throw new IllegalArgumentException("Cannot put tasks for non-existing connector");

        Map<ConnectorTaskId, Map<String, String>> taskConfigsMap = taskConfigListAsMap(connector, configs);
        state.taskConfigs = taskConfigsMap;

        state.applyConfig();

        if (updateListener != null)
            updateListener.onTaskConfigUpdate(taskConfigsMap.keySet());
    }
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