如何调整Kafka-python KafkaAdminClient日志级别 仅输出WARN/ERROR日志

KafkaAdminClient 没有提供专属的初始化配置项用来控制日志输出级别，它的日志完全对接Python标准logging模块，通过配置对应日志器的级别即可屏蔽DEBUG、INFO级日志，仅展示WARN及以上级别的内容。

在初始化客户端前添加如下配置即可：

import logging

# 将kafka全模块日志级别设置为WARNING
logging.getLogger("kafka").setLevel(logging.WARNING)

# 原有客户端初始化逻辑不变
client = KafkaAdminClient(bootstrap_servers=bootstrap_servers,
                          security_protocol=security_protocol,
                          sasl_mechanism=SASL_MECHANISM,
                          sasl_plain_username=username,
                          sasl_plain_password=password,
                          )

配置生效后，节点连接、请求发送这类DEBUG、INFO级日志都会被屏蔽，仅输出告警、错误类日志。

如果需要做细粒度控制，也可以单独给指定子模块设置日志级别：

• 单独屏蔽协议解析模块日志：logging.getLogger("kafka.protocol.parser").setLevel(logging.WARNING)
• 单独屏蔽客户端连接模块日志：logging.getLogger("kafka.client").setLevel(logging.WARNING)

注意：日志级别配置需要在Kafka客户端初始化之前执行；如果项目中已经提前调用过logging.basicConfig()做全局日志配置，kafka模块的日志级别配置要放在全局配置之后，避免被全局规则覆盖。

内容的提问来源于stack exchange，提问作者Tushar