Interface TopicInfo

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

      • getName

        String getName()
        the name of this topic
      • getPartitions

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

        List<Integer> getReplicasPerPartition()
        Returns the number of replicas for each topic partition.
        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.