Interface PartitionHub.ConsumerInfo

  • All Known Subinterfaces:
    Enclosing class:

    public static interface PartitionHub.ConsumerInfo
    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.

    • Method Detail

      • consumerIdByIdx

        long consumerIdByIdx​(int idx)
        Obtain consumer identifier by index
      • getConsumerIds

        java.util.List<java.lang.Object> getConsumerIds()
      • 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.

        consumerId - (undocumented)
      • size

        int size()
        Number of attached consumers.