лететь MESSAGE_TOO_LARGE в батчах. Хотя сообщения не измениились, но какой-то параметр в брокерах нужно подправить. Смотрим в доку и не видим. Кто-то подобное видел?
в доке есть, настройки по размеру сообщений присутсвуют во всех компонентах конфиг брокера, всё что с *.max.bytes https://kafka.apache.org/21/documentation.html#brokerconfigs а также конфигах консюмера и продюсера https://kafka.apache.org/21/documentation.html#newconsumerconfigs https://kafka.apache.org/21/documentation.html#producerconfigs есть про рзамеры сообщений
Обсуждают сегодня