The contract of produceBatched in Legacy module is different from the one in Kafunk right now.
May cause some problems for code that relies on this contract.
A potential fix is that to group by partition instead of groupby partition * offset in implementation of ProduceBatched
The contract of
produceBatched
in Legacy module is different from the one in Kafunk right now. May cause some problems for code that relies on this contract. A potential fix is that to group bypartition
instead of groupbypartition * offset
in implementation of ProduceBatched