private ApiError maybeCheckCreateTopicPolicy(Supplier<CreateTopicPolicy.RequestMetadata> supplier) {
        // AutoMQ for Kafka inject start
        try {
            autoMQCreateTopicPolicy.validate(supplier.get());
            createTopicPolicy.ifPresent(topicPolicy -> topicPolicy.validate(supplier.get()));
        } catch (PolicyViolationException e) {
            return new ApiError(Errors.POLICY_VIOLATION, e.getMessage());
        }
        // AutoMQ for Kafka inject end

        return ApiError.NONE;
    }
Timer for partition reassignment elect timeout.
metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java