Blizzard / Blizzard/node-rdkafka

sendOffsetsToTransaction: incorrect interface

Open
#1,000 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

- 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

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

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.