ConsumerInfo
Namespace: Kafunk
Operations for providing consumer progress information.
Functions and values
| Function or value | Description |
consumerGroupByTopics conn topics
Signature: conn:KafkaConn -> topics:seq<TopicName> -> Async<Map<TopicName,ConsumerGroupInfo []>>
|
Given topic names, returns all of the consumer groups consuming that topic. |
consumerGroups conn
Signature: conn:KafkaConn -> Async<ConsumerGroupInfo []>
|
Returns information about all consumer groups. |
consumerProgress c
Signature: c:Consumer -> Async<ConsumerProgressInfo>
|
Returns consumer progress information for the partitions currently assigned to the consumer. |
progress conn groupId topic ps
Signature: conn:KafkaConn -> groupId:GroupId -> topic:TopicName -> ps:Partition [] -> Async<ConsumerProgressInfo>
|
Returns consumer progress information. Passing empty set of partitions returns information for all partitions. |
