【Practical Combat】Kafka parameetrite häälestus lahendab liiga suure sõnumikeha probleemi

Väike sodi · Postitatud 13.12.2021 16:25:11

Kafka kaudu sõnumeid saadedes on tootja max.request.size vaikimisi järgmine:1048576(1M) suuruses.

Kui tootja sõnumi keha ületab 1MB, teatatakse järgmine viga:

Sõnum on seriaaliseerituna 18685640 baiti, mis on suurem kui 1048576, mis on max.request.size konfiguratsiooni väärtus.

lahus

Näiteks kevadprojektis määra projekti konfiguratsioonifailis maksimaalne päringu suurus20MBJärgmiselt:

Sisselogimine on nähtav.

Pärast seadistamise lõpetamist taaskäivita projekt ja näed, et seaded on edukad, nagu alloleval joonisel näidatud:

Kui saadetud sõnum ületab 1MB, teatatakse uuest veast, järgmiselt:

Päring sisaldas sõnumit, mis oli suurem kui serveri maksimaalne sõnumi suurus.

lahus

Logi sisse Kafka serverisse ja muudaserver.propertiesfaili, lisa järgmine konfiguratsioon:

Sisselogimine on nähtav.

Vaikimisi: 1000012, peaaegu 1M, maksimaalne sõnumite suurus, mida server saab vastu võtta.

Taaskäivita Kafka teenus ja probleem on lahendatud.

Tarbijatele pole muid seadeidNäiteks:

Sisselogimine on nähtav.

(Lõpp)

Väike sodi · Postitatud 13.12.2021 16:31:31

Märkus: See parameeter ei tööta loodud teemal pärast selle muutmist

Muuda loodud teemaparameetreid: bin/kafka-configs.sh --zookeeper localhost:2181 --alter --topic topicName --config max.message.bytes=62914560

Täiuslik lahendus

lendkalad · Postitatud 26.12.2021 17:16:30

Õpi õppima...

【Practical Combat】Kafka parameetrite häälestus lahendab liiga suure sõnumikeha probleemi

Seotud postitused

Vaadatud sektsioonid