Class TopicDescription


  • public class TopicDescription
    extends Object
    A detailed description of a single topic in the cluster.
    • Constructor Detail

      • TopicDescription

        public TopicDescription​(String name,
                                boolean internal,
                                List<TopicPartitionInfo> partitions)
        Create an instance with the specified parameters.
        Parameters:
        name - The topic name
        internal - Whether the topic is internal to Kafka
        partitions - A list of partitions where the index represents the partition id and the element contains leadership and replica information for that partition.
      • TopicDescription

        public TopicDescription​(String name,
                                boolean internal,
                                List<TopicPartitionInfo> partitions,
                                Set<AclOperation> authorizedOperations)
        Create an instance with the specified parameters.
        Parameters:
        name - The topic name
        internal - Whether the topic is internal to Kafka
        partitions - A list of partitions where the index represents the partition id and the element contains leadership and replica information for that partition.
        authorizedOperations - authorized operations for this topic, or null if this is not known.
    • Method Detail

      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class Object
      • name

        public String name()
        The name of the topic.
      • isInternal

        public boolean isInternal()
        Whether the topic is internal to Kafka. An example of an internal topic is the offsets and group management topic: __consumer_offsets.
      • topicId

        public Uuid topicId()
      • partitions

        public List<TopicPartitionInfo> partitions()
        A list of partitions where the index represents the partition id and the element contains leadership and replica information for that partition.
      • authorizedOperations

        public Set<AclOperation> authorizedOperations()
        authorized operations for this topic, or null if this is not known.