【Pratik Savaş】Kafka parametre ayarlaması, çok büyük mesaj gövdesi sorununu çözüyor

Küçük · Yayınlandı 13.12.2021 16:25:11

Kafka ile mesaj gönderilirken, üretici max.request.size varsayılan olarak şu şekilde olur:1048576(1M) boyutunda.

Üretici mesaj gövdesi 1MB'yi aşarsa, aşağıdaki hata bildirilir:

Mesaj serileştirildiğinde 18685640 bayttır ve bu da max.request.size yapılandırmasının değeri olan 1048576'den büyüktür.

çözüm

Örneğin, bahar projesinde, projenin yapılandırma dosyasında maksimum istek boyutunu ayarlayın20MBŞöyle:

Giriş görünür.

Kurulum tamamlandıktan sonra projeyi yeniden başlatın ve aşağıdaki şekilde gösterildiği gibi ayarların başarılı olduğunu görebilirsiniz:

Gönderilen mesaj 1MB'yi aştığında, aşağıdaki gibi yeni bir hata bildirilecektir:

İstek, sunucunun kabul edeceği maksimum mesaj boyutundan daha büyük bir mesaj içeriyordu.

çözüm

Kafka sunucusuna giriş yapın ve değiştirinserver.propertiesdosyasını ekleyerek aşağıdaki yapılandırmayı ekleyin:

Giriş görünür.

Varsayılan: 1000012, yaklaşık 1M, sunucunun alabileceği maksimum mesaj boyutu.

Kafka servisini yeniden başlatın, sorun çözüldü.

Tüketiciler için başka bir ayar yokMesela:

Giriş görünür.

(Son)

Küçük · Yayınlandı 13.12.2021 16:31:31

Not: Bu parametre, oluşturulan konuda ayarlandıktan sonra çalışmaz

Oluşturulan konu parametrelerini ayarlayın: bin/kafka-configs.sh --zookeeper localhost:2181 --alter --topic topicName --config max.message.bytes=62914560

Mükemmel çözüm

uçan balık · Yayınlandı 26.12.2021 17:16:30

Öğrenmeyi öğren...

【Pratik Savaş】Kafka parametre ayarlaması, çok büyük mesaj gövdesi sorununu çözüyor

İlgili Yazılar

Görüntülenen bölümler