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.