【Praktyczna Walka】Strojenie parametrów Kafki rozwiązuje problem zbyt dużej treści komunikatu

Mały śmiecie · Opublikowano 13.12.2021 16:25:11

Podczas wysyłania wiadomości za pomocą Kafki, producent max.request.size domyślnie przyjmuje następujący na:1048576(1M) w rozmiarze.

Jeśli ciało wiadomości producenta przekracza 1MB, zgłaszany jest następujący błąd:

Wiadomość ma 18685640 bajtów po serializacji, co jest większe niż 1048576, czyli wartość konfiguracji max.request.size.

rozwiązanie

Na przykład w projekcie spring ustaw maksymalny rozmiar żądania w pliku konfiguracyjnym projektu20MBNastępujący sposób:

Logowanie jest widoczne.

Po zakończeniu konfiguracji uruchom projekt ponownie i zobaczysz, że ustawienia zakończyły się sukcesem, jak pokazano na poniższym rysunku:

Gdy wysłana wiadomość przekroczy 1MB, zostanie zgłoszony nowy błąd, w następujący sposób:

Żądanie zawierało wiadomość większą niż maksymalny rozmiar wiadomości, jaki serwer zaakceptuje.

rozwiązanie

Zaloguj się na serwer Kafka i zmodyfikujserver.propertiesDodaj następującą konfigurację:

Logowanie jest widoczne.

Domyślne: 1000012, blisko 1M, maksymalny rozmiar wiadomości, jakie serwer może odebrać.

Restartuj usługę Kafka i problem zostaje rozwiązany.

Nie ma innych ustawień dla konsumentówNa przykład:

Logowanie jest widoczne.

(Koniec)

Mały śmiecie · Opublikowano 13.12.2021 16:31:31

Uwaga: Ten parametr nie działa na utworzonym temacie po jego dostosowaniu

Dostosuj utworzone parametry tematu: bin/kafka-configs.sh --zookeeper localhost:2181 --alter --topic topicName --config max.message.bytes=62914560

Idealne rozwiązanie

Ryba Latająca · Opublikowano 26.12.2021 17:16:30

Naucz się uczyć...

【Praktyczna Walka】Strojenie parametrów Kafki rozwiązuje problem zbyt dużej treści komunikatu

Powiązane wpisy

Oglądane sekcje