Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Remove Consumer::stopConsumption #938

Closed
wants to merge 1 commit into from
Closed

Conversation

guizmaii
Copy link
Member

No description provided.

@guizmaii guizmaii requested a review from erikvanoosten as a code owner June 20, 2023 07:46
@guizmaii guizmaii marked this pull request as draft June 20, 2023 08:07
@erikvanoosten
Copy link
Collaborator

There is one problem with this approach. When we interrupt the stream, pending commit may not be completed. When we call stopConsumption, the stream can continue to work on whatever it got and complete without errors.

@guizmaii
Copy link
Member Author

@erikvanoosten As explained in Discord, I think it's a user issue, not a zio-kafka issue. See https://discord.com/channels/629491597070827530/629497941719121960/1120624484035067934

@erikvanoosten
Copy link
Collaborator

erikvanoosten commented Jun 20, 2023

@erikvanoosten As explained in Discord, I think it's a user issue, not a zio-kafka issue. See https://discord.com/channels/629491597070827530/629497941719121960/1120624484035067934

I didn't see that yet. I'll read it!

@svroonland
Copy link
Collaborator

If we have a satisfying way to do this in user space and add that to the docs, I'm all for removing this method and the extra complexity it brings. Did you test it already?

@guizmaii
Copy link
Member Author

guizmaii commented Jun 20, 2023

Did you test it already?

I just started the PR this morning to see what it'd give and what would break.
It needs more work I'll not have time to do this week, focusing on my project.
If you wanna take the subject, go for it :)

Have a look at the discussion I had with a user in Discord. It might be interesting to provide an "interuptor" to the user so that it's easy for them to stop a Stream

For us, it'd probably just be a Promise wrapped in a nice, easy-to-use interface

@guizmaii
Copy link
Member Author

Closed in favour of #941

@guizmaii guizmaii closed this Jun 21, 2023
@guizmaii guizmaii deleted the remove_stopConsumption branch June 21, 2023 05:39
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants