private void maybeCheckCreatePartitionPolicy(CreatePartitionPolicy.RequestMetadata requestMetadata) throws PolicyViolationException {
        createPartitionPolicy.ifPresent(policy -> policy.validate(requestMetadata));
    }
Timer for partition reassignment elect timeout.
metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java