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.

        Returns:
        (undocumented)
      • 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.

        Parameters:
        consumerId - (undocumented)
        Returns:
        (undocumented)
      • size

        int size()
        Number of attached consumers.
        Returns:
        (undocumented)