У меня 30 партиций и кх кластер из 4ёх нод, почему-то они между собой делить партиции не хотят, одна нода берёт все 30, а остальные ничего не делают
и как таблица кафка создана? парамерты? и какая версия кх?
https://dumpz.org/cdZWHXnmFZSn версия 20.10.3
а у остальных 3 КХ есть доступ к брокерам? kafka_broker_list = '192.168.60.30:9092,192.168.60.40:9092,192.168.60.10:9092' ping 192.168.60.30 telnet 192.168.60.30 9092
да, есть доступ, если я одну ноду выключаю, другая всё занимает
Попробую увеличить количество партиций до пару сотен, может поможет
Обсуждают сегодня