и тот же топик
Я хочу чтобы каждый из консьюмеров смотрел в одну партицию, но они очевидно могут упасть и тогда партиция зареасайгнится
Как понять внутри консьюмера что на него заасайгнили еще одну партицию?
ConsumerRebalanceListener Метод onPartitionsAssigned можно переопределить и какую-то свою логику накрутить при переназначении партиций
Обсуждают сегодня