Kafka如何在Java中启用日志记录？

在Kafka的Java客户端代码中，我们可以使用log4j或logback等日志框架来启用日志记录。

以下是使用log4j来启用Kafka日志的示例代码：

1. 添加log4j配置文件（比如log4j.properties）到类路径中：

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] %p %m (%c)%n

2. 在代码中使用Logger来记录日志：

import org.apache.kafka.common.logging.LogContext;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class KafkaProducer {
    private static final Logger log = LoggerFactory.getLogger(KafkaProducer.class);
    private static final LogContext logContext = new LogContext("kafka-producer");

    public void sendMessage(String message) {
        // 在某个地方记录日志
        log.info("sending message: {}", message);
    }
}

此外，还可以在代码中使用LogContext来启用不同类别的日志，例如：

import org.apache.kafka.common.logging.LogContext;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class KafkaConsumer {
    private static final LogContext logContext = new LogContext("kafka-consumer");
    private static final Logger log = logContext.logger(KafkaConsumer.class);

    public void consumeMessage(String message) {
        // 记录INFO级别日志
        log.info("consuming message: {}", message);
        // 记录DEBUG级别日志
        log.debug("debug message: {}", message);
    }
}