Offsets
Namespace: Kafunk
Operations on offsets.
Functions and values
| Function or value | Description |
offsetRange conn topic partitions
Signature: conn:KafkaConn -> topic:TopicName -> partitions:seq<Partition> -> Async<Map<Partition,(Offset * Offset)>>
|
Gets the offset range (Time.EarliestOffset,Time.LatestOffset) for a topic, for the specified partitions. If empty is passed in for Partitions, will return information for all partitions. |
offsets (...)
Signature: conn:KafkaConn -> topic:TopicName -> partitions:seq<Partition> -> times:seq<Time> -> maxOffsets:MaxNumberOfOffsets -> Async<Map<Time,OffsetResponse>>
|
Gets available offsets for the specified topic, at the specified times. Returns a map of times to offset responses. If empty is passed in for Partitions, will return information for all partitions. |
