Re: partition.assignment.strategy for MM2?

2020-09-20 Thread nitin agarwal
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

Re: partition.assignment.strategy for MM2?

2020-09-20 Thread Ning Zhang
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