Kafka日志级别通过yaml文件进行调整

要通过yaml文件调整Kafka日志级别，可以使用Kafka的配置文件来配置日志级别。下面是一个示例代码，展示如何使用yaml文件来配置Kafka日志级别：

首先，创建一个名为log4j.yaml的yaml文件，内容如下：

appenders:
  - name: console
    type: console
    layout:
      type: pattern
      pattern: "%d [%p] %m%n"

rootLogger:
  level: INFO
  appenderRefs:
    - ref: console

loggers:
  - name: org.apache.kafka
    level: DEBUG
    additivity: false
    appenderRefs:
      - ref: console

然后，使用以下代码将该yaml文件加载到Kafka的配置中：

import org.apache.kafka.common.utils.Utils;
import java.io.File;
import java.io.IOException;

public class KafkaLogLevelConfig {
    public static void main(String[] args) {
        File log4jConfigFile = new File("log4j.yaml");
        try {
            String log4jConfigPath = log4jConfigFile.getCanonicalPath();
            System.setProperty("log4j.configurationFile", log4jConfigPath);
        } catch (IOException e) {
            e.printStackTrace();
            return;
        }

        // 其他Kafka相关代码...
    }
}

在上述代码中，我们首先创建一个File对象，指向我们的yaml配置文件。然后，使用getCanonicalPath()方法获取该文件的绝对路径，并将其设置为log4j.configurationFile系统属性。这告诉Kafka使用我们的yaml配置文件作为log4j的配置。

接下来，可以在// 其他Kafka相关代码部分添加任何其他Kafka相关的代码。

当Kafka启动时，它将加载我们的yaml文件并根据其中的配置来设置日志级别。在上述示例中，我们将org.apache.kafka包的日志级别设置为DEBUG，其他包的日志级别设置为INFO。你可以根据自己的需求修改yaml文件中的日志级别配置。

请注意，上述代码假设你已经在项目中添加了log4j2的依赖。如果你还没有添加log4j2依赖，请确保在项目中添加以下依赖：

<dependency>
    <groupId>org.apache.logging.log4j</groupId>
    <artifactId>log4j-core</artifactId>
    <version>2.14.1</version>
</dependency>
<dependency>
    <groupId>org.apache.logging.log4j</groupId>
    <artifactId>log4j-api</artifactId>
    <version>2.14.1</version>
</dependency>
<dependency>
    <groupId>org.apache.logging.log4j</groupId>
    <artifactId>log4j-slf4j-impl</artifactId>
    <version>2.14.1</version>
</dependency>

这样，你就可以使用yaml文件来配置Kafka的日志级别了。