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
Hello,
Following our experimenting with MM2, we seem to have a hard time
recovering from lags created by increased traffic.
Since we're running MM2 on kubernetes, we can easily add more
resources/instances to our MM2 cluster, which should in theory increase the
clusters performance and allow us