@Override
    public void putLoggerLevel(String namespace, String level) {
        log.debug("Writing level {} for logging namespace {} to Kafka", level, namespace);
        Struct value = new Struct(LOGGER_LEVEL_V0);
        value.put("level", level);
        byte[] serializedValue = converter.fromConnectData(topic, value.schema(), value);
        try {
            configLog.sendWithReceipt(LOGGER_CLUSTER_KEY(namespace), serializedValue).get(READ_WRITE_TOTAL_TIMEOUT_MS, TimeUnit.MILLISECONDS);
        } catch (InterruptedException | ExecutionException | TimeoutException e) {
            log.error("Failed to write logger level to Kafka", e);
            throw new ConnectException("Error writing logger level to Kafka", e);
        }
    }
Write a restart request for the connector and optionally its tasks to persistent storage and wait until it has been
acknowledged and read back by tailing the Kafka log with a consumer. {@link #claimWritePrivileges()} must be successfully
invoked before calling this method if the worker is configured to use a fencable producer for writes to the config topic.
@param restartRequest the restart request details
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaConfigBackingStore.java