Добрый день. В топике 3 партиции , хочу распределять сообщения равномерно

по ним.

Почему то сообщения распределяются только по двум партициям.
Даже когда много сообщений пишутся одновременно.

partition 0 - 2370 сообщ.
partition 1 - 711 сообщ.
partition 2 - 0 сообщ.

В качестве ключа сообщения, случайным образом генерирую цифру от 0 до 2
Но сообщения с разными ключами не распределяются по разным партициям.
как это можно исправить?


Написано все на golang , использую github.com/segmentio/kafka-go .
У продюсера указан аргумент Balancer равный &kafka.LeastBytes{}
Как я понял через Balancer задается партишенер, но не работает как надо.

—
Топик читает 3 консюмера в одной группе.
По логам все 3 консюмера подписаны на соответствующие партиции.
С чтением проблем нет.

Без ключа будет roundrobbin-om раскидывать равномерно