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 Summary

    Constructors
    Constructor
    Description
    NewTopic(String name, int numPartitions, short replicationFactor)
    A new topic with the specified replication factor and number of partitions.
    NewTopic(String name, Map<Integer,List<Integer>> replicasAssignments)
    A new topic with the specified replica assignment configuration.
    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.
  • Method Summary

    Modifier and Type
    Method
    Description
    The configuration for the new topic or null if no configs ever specified.
    Set the configuration to use on the new topic.
    boolean
     
    int
     
    The name of the topic to be created.
    int
    The number of partitions for the new topic or -1 if a replica assignment has been specified.
    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.
    short
    The replication factor for the new topic or -1 if a replica assignment has been specified.
     

    Methods inherited from class java.lang.Object

    getClass, notify, notifyAll, wait, wait, wait
  • 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