librdkafka
librdkafka copied to clipboard
Question on Pause/Resume
Hi @edenhill, I am looking on your explanation in https://github.com/confluentinc/librdkafka/issues/1849 and still have questions:
- Whether behavior of latest release of librdkafka is the same?
- You wrote that "partitions will remain paused after a rebalance and re-assignment"(p.3) So how they can be resumed? should they be resumed by consumer they were previously assigned for? Will it work? Does it matter that consumers run on different machines? or co-hosted on the same machine?
- My consumer is high-level and I am using librdkafka's automatic partition assignment/revocation. Can I still use rebalance callback, ot it will automatically turn off librdkafka's automatic partition assignment/revocation?
- I want to pause partitions for only consumer performing the pause. I expect other consumers (running on the same machine or on another machine) will continue to get messages until they by themselves will decide to pause. Can it be implemented this way?
Thanks!!