Skip to content
New issue

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

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

Already on GitHub? # to your account

Support pause/resume of consumer #34

Open
JackMF opened this issue Aug 10, 2021 · 2 comments
Open

Support pause/resume of consumer #34

JackMF opened this issue Aug 10, 2021 · 2 comments

Comments

@JackMF
Copy link

JackMF commented Aug 10, 2021

Is it possible to support this feature here? Is there a road map for other features?

https://kafka.apache.org/0102/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#:~:text=Kafka%20supports%20dynamic%20controlling%20of,future%20poll(long)%20calls.

@silviucpp
Copy link
Owner

Hello,

There is no roadmap for any new feature. Any PR is welcome. I usually implemented the features I'm using in our applications.

Silviu

@JackMF
Copy link
Author

JackMF commented Aug 11, 2021

Hey see this WIP MR to support pause and resuming of consumers: #35

This idea here is to turn the cosnumer into a genstate_m and have a "paused" state and a "polling" state.

Let me know what you think about this approach @silviucpp and I will continue to with the requried changes to -erlkaf_consumer_group and erlkaf_manager so that pasue and resume can be called by the api.

# for free to join this conversation on GitHub. Already have an account? # to comment
Projects
None yet
Development

No branches or pull requests

2 participants