Package org.apache.kafka.clients.admin

Class NewTopic

java.lang.Object
org.apache.kafka.clients.admin.NewTopic
public class NewTopic extends Object
A new topic to be created via Admin.createTopics(Collection).

  • Constructor Details

    • NewTopic

      public NewTopic(String name, int numPartitions, short replicationFactor)
      A new topic with the specified replication factor and number of partitions.

    • NewTopic

      public NewTopic(String name, Optional<Integer> numPartitions, Optional<Short> replicationFactor)
      A new topic that optionally defaults numPartitions and replicationFactor to the broker configurations for num.partitions and default.replication.factor respectively.

    • NewTopic

      public NewTopic(String name, Map<Integer,List<Integer>> replicasAssignments)
      A new topic with the specified replica assignment configuration.
      Parameters:
      name - the topic name.
      replicasAssignments - a map from partition id to replica ids (i.e. broker ids). Although not enforced, it is generally a good idea for all partitions to have the same number of replicas.

  • Method Details

    • name

      public String name()
      The name of the topic to be created.

    • numPartitions

      public int numPartitions()
      The number of partitions for the new topic or -1 if a replica assignment has been specified.

    • replicationFactor

      public short replicationFactor()
      The replication factor for the new topic or -1 if a replica assignment has been specified.

    • replicasAssignments

      public Map<Integer,List<Integer>> replicasAssignments()
      A map from partition id to replica ids (i.e. broker ids) or null if the number of partitions and replication factor have been specified instead.

    • configs

      public NewTopic configs(Map<String,String> configs)
      Set the configuration to use on the new topic.
      Parameters:
      configs - The configuration map.
      Returns:
      This NewTopic object.

    • configs

      public Map<String,String> configs()
      The configuration for the new topic or null if no configs ever specified.

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object