Apache Kafka应用程序的日志默认位置取决于所使用的日志框架和配置。以下是使用log4j作为日志框架的示例解决方法:
log4j
log4j
1.2.17
# 设置日志级别为INFO
log4j.rootLogger=INFO, console
# 控制台输出appender
log4j.appender.console=org.apache.log4j.ConsoleAppender
log4j.appender.console.Target=System.out
log4j.appender.console.layout=org.apache.log4j.PatternLayout
log4j.appender.console.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss} %-5p %c{1}:%L - %m%n
import org.apache.log4j.Logger;
public class KafkaApplication {
private static final Logger logger = Logger.getLogger(KafkaApplication.class);
public static void main(String[] args) {
// 记录一条INFO级别的日志
logger.info("This is an INFO log message");
// 记录一条ERROR级别的日志
logger.error("This is an ERROR log message");
}
}
注意:以上解决方法是使用log4j作为日志框架的示例。实际上,可以使用其他日志框架(如logback)来记录Kafka应用程序的日志。此外,可以根据需要配置日志文件的位置、日志级别等。