Hi
I am using kafka 0.7.1 right now. I am using the following log4j properties file and trying to send some log information to kafka server. log4j.rootLogger=INFO,file,stdout log4j.appender.stdout=org.apache.log4j.ConsoleAppender log4j.appender.stdout.layout=org.apache.log4j.PatternLayout log4j.appender.stdout.layout.ConversionPattern=[%d] %p %t %m (%c)%n log4j.appender.file=org.apache.log4j.RollingFileAppender #log4j.appender.file.FileNamePattern=c:\\development\\producer-agent_%d{yyyy-MM-dd}.log log4j.appender.file.File=${AC_DATA_HOME}\\lmservice\\tailer-aggregator.log log4j.appender.file.MaxFileSize=100MB log4j.appender.file.MaxBackupIndex=1 log4j.appender.file.layout=org.apache.log4j.PatternLayout #log4j.appender.file.layout.ConversionPattern= %-4r [%t] %-5p %c %x - %m%n log4j.appender.file.layout.ConversionPattern=[%d] %p %t %m (%c)%n log4j.appender.KAFKA=kafka.producer.KafkaLog4jAppender log4j.appender.KAFKA.layout=org.apache.log4j.PatternLayout log4j.appender.KAFKA.layout.ConversionPattern=[%d] %p %t %m (%c)%n log4j.appender.KAFKA.BrokerList=0:localhost:9092 log4j.appender.KAFKA.SerializerClass=kafka.serializer.StringEncoder log4j.appender.KAFKA.Topic=test.topic # Turn on all our debugging info log4j.logger.kafka=INFO, KAFKA log4j.logger.org=INFO, KAFKA log4j.logger.com=INFO, KAFKA However, I find that the messages send to kafka server are not formatted as my defined layout. KafkaLog4jAppender just sends messages(%m), and there is no other conversion patterns. I am not sure if my configuration is wrong or KafkaLog4jAppender does not support log4j layout.