Blizzard / Blizzard/node-rdkafka
sendOffsetsToTransaction: incorrect interface
- Dominant language
- JavaScript
- Stars
- 2.2k
- Forks
- 403
- PR merge metrics
- No merged PRs in 30d
Description
- node-rdkafka version 2.14.5
I'm trying to use `producer.sendOffsetsToTransaction()` but I'm having difficulty understanding how it can possibly work given that it accepts a consumer rather than an event. My consumer binds to topics through a regex and has many consumer groups performing different tasks when a message is received.
If I want to bind a producer tx to a consumed message, I should explicitly name the topic and group offset (found in the message), right? But, I can't.
If the interface is correct, how should this work?
TIA
B
Contributor guide
Research direction
Start with the producer.sendOffsetsToTransaction() entry point and review its documented consumer and offset arguments alongside Kafka transaction semantics. The issue provides no file or test location; done would require confirming whether the interface is correct and, if not, defining a scoped API or documentation change.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- 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