我使用streamparse在构建中具有拓扑结构,它接收来自kafka的输入,稍后spout将消息传输到主螺栓,主螺栓计算并生成10 MB消息,并且该消息必须传递给其他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
据我所知,最大消息大小完全由您的最大堆大小决定,因此它将取决于您的RAM和JVM配置。如果您达到10 MB的限制,我会感到惊讶。