2012-12-20 28 views
0

我正在运行使用log4j进行日志记录的Storm群集。除了标准的基于文件的日志记录之外,我想添加一个kafka appender。log4j kafka appender未使用defined ConversionPattern

我log4j的配置文件看起来是这样的:

log4j.rootLogger=INFO, A1 

log4j.appender.A1 = org.apache.log4j.DailyRollingFileAppender 
log4j.appender.A1.File = /var/log/storm/logs/${logfile.name} 
log4j.appender.A1.Append = true 
log4j.appender.A1.DatePattern = '.'yyy-MM-dd 
log4j.appender.A1.layout = org.apache.log4j.PatternLayout 
log4j.appender.A1.layout.ConversionPattern = %d{yyyy-MM-dd HH:mm:ss} %c{1} [%p] %m%n 

log4j.appender.KAFKA=kafka.producer.KafkaLog4jAppender 
log4j.appender.KAFKA.Host=<kafka.ip> 
log4j.appender.KAFKA.Port=9092 
log4j.appender.KAFKA.Topic=storm_log 
log4j.appender.KAFKA.SerializerClass=kafka.producer.DefaultStringEncoder 
log4j.appender.KAFKA.layout=org.apache.log4j.PatternLayout 
log4j.appender.KAFKA.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss} %c{1} [%p] %m%n 

log4j.logger.my.package.name=INFO, KAFKA 

一切工作正常,除了卡夫卡附加器不使用的定义ConversionPattern,即使定义是完全一样的文件附加目的地相同,它按预期工作。我如何改变配置来使卡夫卡appender工作?

回答

1

我和Kafka版本0.7有同样的问题。

版本0.7.1中对KafkaLog4jAppender进行了一些更改,升级后,ConversionPattern对我的配置类似于上面的配置。