Interface TopicInfo


public interface TopicInfo
Metadata for a Kafka topic available for use with ksqlDB.
  • Method Details

    • getName

      String getName()
      Returns:
      the name of this topic
    • getPartitions

      int getPartitions()
      Returns:
      the number of partitions for this topic
    • getReplicasPerPartition

      List<Integer> getReplicasPerPartition()
      Returns the number of replicas for each topic partition.
      Returns:
      a list with size equal to the number of partitions. Each element is the number of replicas for the partition corresponding to the list index.