我是一个新的ot apache Kafka和log4j.我正在尝试将我的日志消息发送到Kafka.这是我的log4j属性文件
log4j.rootLogger=INFO, stdout
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss} %-5p %c{1}:%L %% %m%n
log4j.appender.KAFKA=kafka.producer.KafkaLog4jAppender
log4j.appender.KAFKA.BrokerList=localhost:9092
log4j.appender.KAFKA.Topic=kfkLogs
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} %-5p %c{1}:%L %% - %m%n
log4j.logger.logGen=DEBUG, KAFKA
但是,我无法在消费者中收到任何消息.我用其他一些生产者代码测试了消费者,它运行正常.
另外,我收到了这个警告
log4j:WARN No such property [serializerClass] in kafka.producer.KafkaLog4jAppender.
编辑
这是生成我的日志消息的代码
package logGen;
import org.apache.log4j.Logger;
public class TestLog4j {
static Logger log = Logger.getLogger(TestLog4j.class.getName());
public static void main(String[] args) {
log.debug("Debug message");
log.info("Info message");
log.error("Error Message");
log.fatal("Fatal Message");
log.warn("Warn Message");
log.trace("Trace Message");
}
}
此外,如果我使用类似的东西将日志消息写入文件
log4j.appender.KAFKA=org.apache.log4j.DailyRollingFileAppender
log4j.appender.KAFKA.DatePattern='.'yyyy-MM-dd-HH
log4j.appender.KAFKA.File=logs/server.log
我可以在server.log文件中看到日志消息
感谢大家的建议.我认为我看到的奇怪行为可能与我的卡夫卡设置有关.这是我用来启动我的kafka服务器的server.properties文件的内容.你能看到有什么奇怪的吗？
broker.id=0
port=9092
num.network.threads=3 …