...
Code Block | ||
---|---|---|
| ||
package org.apache.kafka.server.policy; import org.apache.kafka.common.Configurable; public interface CreateTopicPolicy extends Configurable, AutoCloseable { void validate(TopicDetails topicDetails) throws 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; /** 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; this.numPartitions = numPartitions; this.replicationFactor = replicationFactor; this.replicasAssignments = replicasAssignments; this.configs = configs; } } |
...