Class NewTopic

    • Constructor Summary

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

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      java.util.Map<java.lang.String,​java.lang.String> configs()
      The configuration for the new topic or null if no configs ever specified.
      NewTopic configs​(java.util.Map<java.lang.String,​java.lang.String> configs)
      Set the configuration to use on the new topic.
      boolean equals​(java.lang.Object o)  
      int hashCode()  
      java.lang.String name()
      The name of the topic to be created.
      int numPartitions()
      The number of partitions for the new topic or -1 if a replica assignment has been specified.
      java.util.Map<java.lang.Integer,​java.util.List<java.lang.Integer>> replicasAssignments()
      A map from partition id to replica ids (i.e.
      short replicationFactor()
      The replication factor for the new topic or -1 if a replica assignment has been specified.
      java.lang.String toString()  
      • Methods inherited from class java.lang.Object

        clone, finalize, getClass, notify, notifyAll, wait, wait, wait
    • Constructor Detail

      • NewTopic

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

        public NewTopic​(java.lang.String name,
                        java.util.Optional<java.lang.Integer> numPartitions,
                        java.util.Optional<java.lang.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​(java.lang.String name,
                        java.util.Map<java.lang.Integer,​java.util.List<java.lang.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 Detail

      • name

        public java.lang.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 java.util.Map<java.lang.Integer,​java.util.List<java.lang.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​(java.util.Map<java.lang.String,​java.lang.String> configs)
        Set the configuration to use on the new topic.
        Parameters:
        configs - The configuration map.
        Returns:
        This NewTopic object.
      • configs

        public java.util.Map<java.lang.String,​java.lang.String> configs()
        The configuration for the new topic or null if no configs ever specified.
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object
      • equals

        public boolean equals​(java.lang.Object o)
        Overrides:
        equals in class java.lang.Object
      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class java.lang.Object