0
로깅을 위해 log4j를 사용하는 스톰 클러스터를 실행 중입니다. 표준 파일 기반 로깅 외에도 kafka appender를 추가하고 싶습니다.log4j kafka appender가 정의 된 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를 사용하지 않는 것을 제외하고 잘 작동, 의도 한대로 작동합니다. kafka appender가 작동하도록 구성을 어떻게 변경해야합니까?