1

我有一个负责提取电子邮件内容的风暴螺栓。我想在我选择的日志文件中而不是在 worker.log 中记录有关电子邮件的一些详细信息。螺栓确实记录到 worker.log 中的错误等，我希望它继续这样做。

我已经更新了 cluster.xml 以包含新的记录器

<configuration monitorInterval="60" shutdownHook="disable">
        <properties>
            <property name="pattern">%d{yyyy-MM-dd HH:mm:ss.SSS} %c{1.} %t [%p] %msg%n</property>
        </properties>
        <appenders>
            <RollingFile name="A1" immediateFlush="false"
                fileName="${sys:storm.log.dir}/${sys:logfile.name}"
                filePattern="${sys:storm.log.dir}/${sys:logfile.name}.%i.gz">
                <PatternLayout>
                    <pattern>${pattern}</pattern>
                </PatternLayout>
                <Policies>
                    <SizeBasedTriggeringPolicy size="100 MB"/>
                </Policies>
                <DefaultRolloverStrategy max="9"/>
            </RollingFile>
            <RollingFile name="TEST-SIZE" immediateFlush="false"
                fileName="${sys:storm.log.dir}/test_debug.log"
                filePattern="${sys:storm.log.dir}/test_debug.log.%i.gz">
            <PatternLayout>
                <pattern>${pattern}</pattern>
            </PatternLayout>
                <Policies>
                    <SizeBasedTriggeringPolicy size="100 MB"/>
                </Policies>
                <DefaultRolloverStrategy max="9"/>
            </RollingFile>
            <Syslog name="syslog" format="RFC5424" charset="UTF-8" host="localhost" port="514"
                protocol="UDP" appName="[${sys:daemon.name}]" mdcId="mdc" includeMDC="true"
                facility="LOCAL5" enterpriseNumber="18060" newLine="true" exceptionPattern="%rEx{full}"
                messageId="[${sys:user.name}:S0]" id="storm" immediateFlush="true" immediateFail="true"/>
    </appenders>
    <loggers>
        <Logger name="TestSizeLogger" level="info" additivity="false">
            <AppenderRef ref="TEST-SIZE"/>
            <AppenderRef ref="syslog"/>
        </Logger>
        <root level="info"> <!-- We log everything -->
            <appender-ref ref="A1"/>
            <appender-ref ref="syslog"/>
        </root>
    </logger>

然后在我的 Java 代码中创建两个记录器实例，但它们都记录到 worker.log

static Logger logger = LoggerFactory.getLogger(ExtractorBolt.class);
static Logger testLogger = LoggerFactory.getLogger("TestSizeLogger");

关于如何让我的 testLogger 登录到我的新日志文件的任何建议，我将不胜感激。

4

1 回答 1

1

cluster.xml 用于配置 Nimbus、主管和其他守护进程的日志记录。您应该编辑 log4j2/worker.xml 文件以配置工作人员日志记录。

于 2018-09-26T15:52:48.420 回答