Package org.apache.kafka.clients.admin

Class StreamsGroupSubtopologyDescription.TopicInfo

java.lang.Object
org.apache.kafka.clients.admin.StreamsGroupSubtopologyDescription.TopicInfo
Enclosing class:
StreamsGroupSubtopologyDescription
public static class StreamsGroupSubtopologyDescription.TopicInfo extends Object
Information about a topic. These configs reflect what is required by the topology, but may differ from the current state on the broker.

  • Constructor Details

    • TopicInfo

      public TopicInfo(int partitions, int replicationFactor, Map<String,String> topicConfigs)

  • Method Details

    • partitions

      public int partitions()
      The number of partitions in the topic. Can be 0 if no specific number of partitions is enforced.

    • replicationFactor

      public int replicationFactor()
      The replication factor of the topic. Can be 0 if the default replication factor is used.

    • topicConfigs

      public Map<String,String> topicConfigs()
      Topic-level configurations as key-value pairs. Default configuration can be omitted.

    • equals

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

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • toString

      public String toString()
      Overrides:
      toString in class Object