Interface ThroughputLimiter.Context

    • Method Detail

      • getConsumedPartitions

        java.util.Collection<Partition> getConsumedPartitions()
        Get collection of Partitions associated with reader reading with this limiter
        Returns:
        list of associated partitions
      • getMinWatermark

        long getMinWatermark()
        Retrieve current reader's watermark (minimum of all partitions).
        Returns:
        minimal watermark within partitions