Blizzard / Blizzard/node-rdkafka
How to properly use seek()?
- Dominant language
- JavaScript
- Stars
- 2.2k
- Forks
- 403
- PR merge metrics
- No merged PRs in 30d
Description
I'm currently using seek() to start fetching the specific offset I want to consume. However, it seems to be not working when I call consumer.pause() then call the seek before calling the consumer.resume() to start consuming with the offset I specified on the seek method. Is there something wrong with seek()? I'm currently using node-rdkafka:2.10.0
Contributor guide
Research direction
Start by reproducing the reported sequence in node-rdkafka 2.10.0: call consumer.pause(), seek() to the requested offset, then consumer.resume(). Read the consumer pause, seek, and resume entry points and verify whether consumption begins at that offset; done means the behavior is explained and a reproducible fix or documented usage is established.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- javascript, kafka, nodejs
- Domain
- stream-processing
- Issue type
- Bug
- Difficulty
- 4/5
- Estimated time
- 3-5 days
- Activity status
- Stale
- Clarity
- Needs clarification
- Newbie friendliness
- 20/100