Skip to content
This repository has been archived by the owner on Nov 20, 2020. It is now read-only.

Request adding a consume function readToOffsets #162

Closed
jingle3276 opened this issue Aug 18, 2017 · 1 comment
Closed

Request adding a consume function readToOffsets #162

jingle3276 opened this issue Aug 18, 2017 · 1 comment

Comments

@jingle3276
Copy link

Add a function readToOffsets consumer Map<Partition, Offset>: AsyncSeq<ConsumerState* ConsumerMessageSet>
where the returned AsyncSeq knows where to stop based on the input map
@eulerfx
Copy link
Contributor

eulerfx commented Oct 13, 2017

This has been added as Consumer.streamRange as of 0.1.5

@eulerfx eulerfx closed this as completed Oct 13, 2017
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
2 participants
@eulerfx @jingle3276