Package akka.stream.javadsl
Interface PartitionHub.ConsumerInfo
-
- All Known Subinterfaces:
PartitionHub.ConsumerInfo
- Enclosing class:
- PartitionHub
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 Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description long
consumerIdByIdx(int idx)
Obtain consumer identifier by indexjava.util.List<java.lang.Object>
getConsumerIds()
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()
-
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)
-
-