Всем привет! Есть проблема: Используем оператор strimzi для выката кафки, дебезиум выступает

Question

Всем привет! Есть проблема: Используем оператор strimzi для выката кафки, дебезиум выступает

продьюсером, а также используем стримы через ksql.
Хотелось бы, чтобы стримы дистрибьютили сообщения равномерно (RoundRobin)
нашел в доке оператора (https://strimzi.io/docs/operators/latest/configuring.html#con-partition-reassignment-str) возможность установить RoundRobinPartitioner явно: partitioner.class: RoundRobinPartitioner

Но к сожалению, это не помогло и все равно сообщения распределяются неравномерно

Кто может подсказать, с чем это может быть связано?
(Есть предположения, что это из-за того, что один топик имеет всего две партиции, а другой, который его читает через стрим - 6)

#kafka #russian #software

0

18.02.2022