Interface PartitionHub.ConsumerInfo

    • Method Detail

      • consumerIds

        scala.collection.immutable.IndexedSeq<java.lang.Object> consumerIds()
        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.

        Specified by:
        queueSize in interface PartitionHub.ConsumerInfo
        Parameters:
        consumerId - (undocumented)
        Returns:
        (undocumented)