Не могу отправить большое сообщение Кафка - PullRequest
1 голос
/ 22 марта 2019

Я пытаюсь отправить сообщение размером 10770128 байт через Кафку.Я получаю следующую ошибку:

org.apache.kafka.common.errors.RecordTooLargeException: The message is 10770128 bytes when serialized which is larger than the maximum request size you have configured with the max.request.size configuration.

Я прошел и добавил следующие параметры для server.properties, Manufacturer.properties и consumer.properties.

replica.fetch.max.bytes =12000000
message.max.bytes=12000000
max.message.bytes=12000000
max.request.size=12000000
max.message.max.bytes=12000000
max.partition.fetch.bytes=12000000

thisявляется трехузловым кластером кафкиКаждый узел имеет вышеуказанные настройки в каждом файле.Любая помощь приветствуется.Спасибо:)

Редактировать: я уже пытался увидеть конфигурации Здесь , но проблема сохраняется

...