如何阻止confluent-kafka-python消费者出现遥测实例ID变更日志？

这条日志是confluent-kafka-python底层依赖librdkafka的遥测模块输出的INFO级别日志，本身不会影响消费者的分区分配或消息消费功能，无需担心功能异常。

为什么仅在Kubernetes集群中出现？ #

本地环境中，librdkafka的遥测客户端初始化时能直接基于稳定的主机标识、文件系统生成有效实例ID；而K8s容器环境存在隔离特性（临时文件系统、动态主机名等），遥测客户端首次初始化时会生成默认占位ID（即AAAAAAAAAAAAAAAAAAAAAA），在后续分区分配阶段的订阅信息获取流程中，会重新生成随机实例ID，因此触发这条变更日志。

解决方法 #

如果觉得这条日志冗余干扰，可通过以下两种方式处理：

1. 调整日志级别
   将librdkafka的日志级别调至WARNING及以上，过滤掉INFO级别的日志。在消费者配置中添加log_level参数：

consumer_config = {
    "bootstrap.servers": "your-kafka-broker-list",
    "group.id": "your-consumer-group",
    "auto.offset.reset": "latest",
    "log_level": 4  # 对应WARNING级别，仅输出警告及更严重的日志
}

2. 禁用遥测功能
   直接关闭librdkafka的遥测模块，彻底消除相关日志输出。在消费者配置中添加enable.telemetry参数：

consumer_config = {
    "bootstrap.servers": "your-kafka-broker-list",
    "group.id": "your-consumer-group",
    "auto.offset.reset": "latest",
    "enable.telemetry": False
}

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