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?
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