Каков максимальный размер сообщения, которое может быть передано от одного болта к другому в топологии - PullRequest
Новая
       26

Каков максимальный размер сообщения, которое может быть передано от одного болта к другому в топологии

0 голосов
/ 04 ноября 2019

У меня топология в сборке с использованием streamparse, она получает данные от kafka, а затем spout передает сообщение на мастер-болт, мастер-болт вычисляет и генерирует 10 МБ сообщения, и это сообщение должно быть передано другим 3 болтам.

Данные успешно генерируются в главном болте, но при переносе на другой болт появляется следующая ошибка

ERROR Unable to write to stream UDP:localhost:514 for appender syslog: org.apache.logging.log4j.core.appender.AppenderLoggingException: Error flushing stream UDP:localhost:514

1 Ответ

0 голосов
/ 04 ноября 2019

Журнал, который вы разместили, похоже, не имеет никакого отношения к размеру сообщения. Он говорит, что не может записать журнал на localhost: 514. Может быть, у вас неправильно настроено ведение журнала?

Насколько я знаю, максимальный размер сообщения определяется исключительно вашим максимальным размером кучи, поэтому он будет зависеть от вашей оперативной памяти и конфигурации JVM. Я был бы удивлен, если вы превысили лимит в 10 МБ.

...