【Practical Combat】Настройката на параметрите на Кафка решава проблема с твърде голямото тяло на съобщението

Малък боклук · Публикувано в 13.12.2021 г. 16:25:11 ч.

При изпращане на съобщения чрез Kafka, producer max.request.size по подразбиране на:1048576(1М) по размер.

Ако тялото на съобщението на производителя надвиши 1MB, се докладва следната грешка:

Съобщението е 18685640 байта при сериализация, което е по-голямо от 1048576, което е стойността на конфигурацията max.request.size.

решение

Например, в пролетния проект задайте максималния размер на заявката в конфигурационния файл на проекта20MBКакто следва:

Входът е видим.

След като настройката приключи, рестартирайте проекта и ще видите, че настройките са успешни, както е показано на фигурата по-долу:

Когато изпратеното съобщение надвиши 1MB, ще бъде докладвана нова грешка, както следва:

Заявката включваше съобщение, по-голямо от максималния размер, който сървърът ще приеме.

решение

Влезте в Kafka сървъра и модифицирайтеserver.propertiesДобавете следната конфигурация:

Входът е видим.

По подразбиране: 1000012, близо до 1M, максималният размер на съобщенията, които сървърът може да получи.

Рестартирай услугата Kafka и проблемът е решен.

Няма други настройки за потребителитеНапример:

Входът е видим.

(Край)

Малък боклук · Публикувано в 13.12.2021 г. 16:31:31 ч.

Забележка: Този параметър не работи върху създадената тема след корекция

Коригирайте създадените параметри на темата: bin/kafka-configs.sh --zookeeper localhost:2181 --alter --topic topicName --config max.message.bytes=62914560

Перфектно решение

Летящи риби · Публикувано в 26.12.2021 г. 17:16:30 ч.

Научи се да учиш...

【Practical Combat】Настройката на параметрите на Кафка решава проблема с твърде голямото тяло на съобщението

Свързани публикации

Разгледани секции