【Combat practic】Ajustarea parametrilor Kafka rezolvă problema corpului prea mare al mesajului

Mică mizerie · Postat pe 13.12.2021 16:25:11

Când se trimit mesaje folosind Kafka, producătorul max.request.size este implicit la:1048576(1M) ca mărime.

Dacă corpul mesajului producătorului depășește 1MB, se raportează următoarea eroare:

Mesajul are 18685640 octeți când este serializat, ceea ce este mai mare decât 1048576, care reprezintă valoarea configurației max.request.size.

soluție

De exemplu, în proiectul de primăvară, setează dimensiunea maximă a cererii în fișierul de configurare al proiectului20MBAșa cum urmează:

Autentificarea este vizibilă.

După ce configurarea este finalizată, reporniți proiectul și puteți vedea că setările au fost reușite, așa cum se vede în figura de mai jos:

Când mesajul trimis depășește 1MB, va fi raportată o nouă eroare, după cum urmează:

Cererea a inclus un mesaj mai mare decât dimensiunea maximă a mesajului pe care serverul îl va accepta.

soluție

Conectează-te pe serverul Kafka și modifică-teserver.proprietățiadaugă următoarea configurație:

Autentificarea este vizibilă.

Implicit: 1000012, aproape de 1M, dimensiunea maximă a mesajelor pe care serverul le poate primi.

Repornește serviciul Kafka și problema este rezolvată.

Nu există alte setări pentru consumatoriDe exemplu:

Autentificarea este vizibilă.

(Sfârșit)

Mică mizerie · Postat pe 13.12.2021 16:31:31

Notă: Acest parametru nu funcționează pe subiectul creat după ce este ajustat

Ajustează parametrii topic creați: bin/kafka-configs.sh --zookeeper localhost:2181 --alter --topicName --config max.message.bytes=62914560

Soluția perfectă

Pești zburători · Postat pe 26.12.2021 17:16:30

Învață să înveți...

【Combat practic】Ajustarea parametrilor Kafka rezolvă problema corpului prea mare al mesajului

Postări conexe

Secțiuni vizualizate