механизм возникновения ошибки. Смотрю доки - partition max bytes = int32. Каким образом может быть не корректное значение. Я issue этот читал и не совсем понял
Я с этой проблемой не сталкивался. Из идей - можно поиграться с настройкой replica.fetch.max.bytes, у нас 1048576 (1MB) . Ну или накатить патч из задачи.
Обсуждают сегодня