Kafka: How do I enable customer logging?

When I create a Kafka client

KafkaConsumer<String,String> consumer = new KafkaConsumer<String,String>(props); 

I get this message

 SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder". SLF4J: Defaulting to no-operation (NOP) logger implementation SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details. 

How do I enable logging for my client program?

+7
java logging slf4j apache-kafka
source share
1 answer

Add this src/main/resources/log4j.properties to your project:

 $ cat src/main/resources/log4j.properties # Root logger option log4j.rootLogger=DEBUG, stdout # Direct log messages to stdout log4j.appender.stdout=org.apache.log4j.ConsoleAppender log4j.appender.stdout.Target=System.out 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 

This will allow you to keep a journal. Then you can set standard parameters such as debug level, output format, etc. in accordance with the documentation for logging.

+8
source share

All Articles