Blizzard / Blizzard/node-rdkafka
consume from a specific partition
- Dominant language
- JavaScript
- Stars
- 2.2k
- Forks
- 403
- PR merge metrics
- No merged PRs in 30d
Description
I have 6 partitions and 3 consumers. I need to assign partition1 and partition2 to consumer1, partition3 and partition5 to consumer2, partition4 and partition6 to the consumer3. I tried with assign() function, but it's not giving the expected result. I am using confluent kafka with node-rdkafka library.
Contributor guide
Research direction
Start by reading node-rdkafka's assign() entry point and the Kafka partition-assignment behavior relevant to the six-partition, three-consumer setup. Reproduce the requested mapping and compare it with the observed result; done means the cause and supported configuration are documented or a focused fix is identified.
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
- 25/100