将Apache Storm Log4j2系统日志附加程序从UDP更改为TCP Download


在我的Storm拓扑中，我通过Kafka喷口将大量JSON数据传输到ElasticSearch螺栓。

问题是Apache Storm使用的Log4j2在cluster和worker的配置中都使用UDP协议：

Log4j2 / Worker.xml： 

    <Syslog name="syslog" format="RFC5424" charset="UTF-8" host="localhost" port="514"
        protocol="UDP" appName="[${sys:storm.id}:${sys:worker.port}]" mdcId="mdc" includeMDC="true"
        facility="LOCAL5" enterpriseNumber="18060" newLine="true" exceptionPattern="%rEx{full}"
        messageId="[${sys:user.name}:${sys:logging.sensitivity}]" id="storm" immediateFail="true" 
        immediateFlush="true"/>

结果-在提交拓扑时，我收到下一个错误：

  

错误无法写入流UDP：localhost：514的附加程序syslog   org.apache.logging.log4j.core.appender.AppenderLoggingException：错误   冲洗流UDP：localhost：514

这是由于消息长度所致。

我想知道是否可以将Apache Storm Syslog附加程序的默认协议从UDP更改为TCP？

0 个答案:

没有答案



Similar searches