Page History

package org.apache.kafka.server.policy;
 
import org.apache.kafka.common.Configurable;
public interface CreateTopicPolicy extends Configurable, AutoCloseable {

  void validate(TopicDetails topicDetails)class throwsRequestMetadata InvalidRequestException;
}

public class TopicDetails {
{
        private final String topic;
        private final int numPartitions;
        private final short replicationFactor;
        private final Map<Integer, List<Integer>> replicasAssignments;
        private final Map<String, String> configs;

        public RequestMetadata(String topic, int numPartitions, short replicationFactor,
         /** replicasAssignment is a map from partition id to broker ids */
    public TopicDetails(String topic, int numPartitions, short replicationFactor, Map<Integer, List<Integer>> replicasAssignments, Map<String, String> configs) {
			...
        this.topic = topic;
}

        public String topic() {
            return topic;
        }

        public this.int numPartitions =() {
            return numPartitions;
        }

      this.replicationFactor = replicationFactor;
  public Map<Integer, List<Integer>> replicasAssignments() {
           this.replicasAssignments =return replicasAssignments;
        }

  this.configs = configs;
	      public Map<String, String> configs() {
            return configs;
        }

    }

    void validate(RequestMetadata requestMetadata) throws PolicyViolationException;
}
 
package org.apache.kafka.common.errors;

public class PolicyViolationException extends ApiException {

    public PolicyViolationException(String message) {
        super(message);
    }

    public PolicyViolationException(String message, Throwable cause) {
        super(message, cause);
    }
}