Kafka：如何启用客户端日志记录？

当我实例化Kafka消费者时

KafkaConsumer consumer = new KafkaConsumer(props); 

我收到这条消息

 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. 

如何为客户端程序启用日志记录？

Answer 1

将此属性文件src/main/resources/log4j.properties到您的项目：

 $ 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 

这将启用日志记录。 然后，您可以根据日志记录文档设置标准选项，如调试级别，输出格式等。