Package org.apache.pekko.stream.javadsl

Interface PartitionHub.ConsumerInfo

Enclosing class:
PartitionHub
public static interface PartitionHub.ConsumerInfo

  • Method Summary

    Modifier and Type
    Method
    Description
    long
    consumerIdByIdx(int idx)
    Obtain consumer identifier by index
    List<Object>
    getConsumerIds()
    Sequence of all identifiers of current consumers.
    int
    queueSize(long consumerId)
    Approximate number of buffered elements for a consumer.
    int
    size()
    Number of attached consumers.

  • Method Details

    • consumerIdByIdx

      long consumerIdByIdx(int idx)
      Obtain consumer identifier by index

    • getConsumerIds

      List<Object> getConsumerIds()
      Sequence of all identifiers of current consumers.

      Use this method only if you need to enumerate consumer existing ids. When selecting a specific consumerId by its index, prefer using the dedicated consumerIdByIdx(int) method instead, which is optimised for this use case.

    • queueSize

      int queueSize(long consumerId)
      Approximate number of buffered elements for a consumer. Larger value than other consumers could be an indication of that the consumer is slow.

      Note that this is a moving target since the elements are consumed concurrently.

    • size

      int size()
      Number of attached consumers.