Class CreateTopicPolicy.RequestMetadata

  • Enclosing interface:
    CreateTopicPolicy

    public static class CreateTopicPolicy.RequestMetadata
    extends Object
    Class containing the create request parameters.
    • Constructor Detail

      • RequestMetadata

        public RequestMetadata​(String topic,
                               Integer numPartitions,
                               Short replicationFactor,
                               Map<Integer,​List<Integer>> replicasAssignments,
                               Map<String,​String> configs)
        Create an instance of this class with the provided parameters. This constructor is public to make testing of CreateTopicPolicy implementations easier.
        Parameters:
        topic - the name of the topic to created.
        numPartitions - the number of partitions to create or null if replicasAssignments is set.
        replicationFactor - the replication factor for the topic or null if replicaAssignments is set.
        replicasAssignments - replica assignments or null if numPartitions and replicationFactor is set. The assignment is a map from partition id to replica (broker) ids.
        configs - topic configs for the topic to be created, not including broker defaults. Broker configs are passed via the configure() method of the policy implementation.
    • Method Detail

      • topic

        public String topic()
        Return the name of the topic to create.
      • numPartitions

        public Integer numPartitions()
        Return the number of partitions to create or null if replicaAssignments is not null.
      • replicationFactor

        public Short replicationFactor()
        Return the number of replicas to create or null if replicaAssignments is not null.
      • replicasAssignments

        public Map<Integer,​List<Integer>> replicasAssignments()
        Return a map from partition id to replica (broker) ids or null if numPartitions and replicationFactor are set instead.
      • configs

        public Map<String,​String> configs()
        Return topic configs in the request, not including broker defaults. Broker configs are passed via the configure() method of the policy implementation.