kafka log出错

一如乞人不需要形象 发表于: 2020-07-12   最后更新时间: 2020-07-12 18:16:08   1,065 游览

起kafka connect,log不保存到connect.log里,且连debug的log都打出来了,connect-log4j.properties用的是原本就有的:

log4j.rootLogger=INFO, stdout, connectAppender

log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout

log4j.appender.connectAppender=org.apache.log4j.DailyRollingFileAppender
log4j.appender.connectAppender.DatePattern='.'yyyy-MM-dd-HH
log4j.appender.connectAppender.File=${kafka.logs.dir}/connect.log
log4j.appender.connectAppender.layout=org.apache.log4j.PatternLayout

connect.log.pattern=[%d] %p %m (%c:%L)%n

log4j.appender.stdout.layout.ConversionPattern=${connect.log.pattern}
log4j.appender.connectAppender.layout.ConversionPattern=${connect.log.pattern}

log4j.logger.org.apache.zookeeper=ERROR
log4j.logger.org.reflections=ERROR

用的这个语句:

nohup  connect-distributed.sh /opt/kafka/config/connect-distributed.properties  > /dev/null 2>&1 &
发表于 2020-07-12

log不保存到connect.log里,且连debug的log都打出来了
这句话没听懂,感觉很矛盾。

就是配置的是INFO级别的,且保存在connect.log文件里,但控制台打印的log是DEBUG级别,且没有保存到connect.log文件中。目前发现可能是connector.jar包里也有slf4J/impl/StaticLoggerBinder.class ,冲突导致的,大佬觉得呢?

connect-log4j.properties是你自己改的吧,另外生不生效你不知道,你把控台日志打开,先看看读取的是哪个log4j配置文件。(也就是>/dev/null 2>&1 &
另外,你参考一下log4j.properties,没看到你指定对应的类路径(如log4j.logger.kafka.log.LogCleaner=INFO, cleanerAppender

你的答案

查看kafka相关的其他问题或提一个您自己的问题