If I understand correctly there is only one consumer object created per
task, how would the setting of partition.assignment.strategy help here ?
Thanks,
Nitin
On Sun, Sep 20, 2020 at 10:37 PM Ning Zhang wrote:
> Here my initial thoughts:
>
> (1) MM2 assigned partitions over tasks based on
Here my initial thoughts:
(1) MM2 assigned partitions over tasks based on round-robin at the MM2
application level:
https://github.com/apache/kafka/commit/4fe324b5a696d47ae8414cf030ae36b83a2cf163#diff-bf03ad7a93c070fe11fcf88f897e0973
(2) if want to try out `RoundRobinAssignor` in