Interface PartitionHub.ConsumerInfo

  • Enclosing class:
    PartitionHub

    public static interface PartitionHub.ConsumerInfo
    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      long consumerIdByIdx​(int idx)
      Obtain consumer identifier by index
      java.util.List<java.lang.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 Detail

      • consumerIdByIdx

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

        java.util.List<java.lang.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.