Blizzard / Blizzard/node-rdkafka

How to properly use seek()?

Open
#977 0 comments 0 reactions 0 assignees View on GitHub
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

Open the contributing 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

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.