Telegraf v1.34.2连接OneNet MQTT v3.1.1报协议版本错误求助

核心配置修正 #

你的Telegraf配置存在几个关键问题，先给出修正后的核心配置片段：

[outputs.influxdb_v2]
urls = ["us-east-1-1.aws.cloud2.influxdata.com"]
token = "$token*******************************"
organization = "none"
bucket = "ESP32_Gateway"

[[inputs.mqtt_consumer]]
servers = ["tcp://mqtt.heclouds.com:1883"] # 明文连接，若用SSL则改为tcp://mqtts.heclouds.com:8883
topics = [ "$sys/N62VRZ6YgE/DHT11/thing/property/post/reply", ]
client_id = "DHT11"
username = "*********"
password = "*************************************"
data_format = "json"
protocol_version = "3.1.1" # 强制指定MQTT协议版本
# 若使用SSL端口8883，可添加以下配置
# insecure_skip_verify = true # 仅测试用，跳过证书验证

针对你的问题的解答 #

1. 是否需要特定配置确保Telegraf连接OneNet时使用MQTT v3.1.1？ #

需要。Telegraf的mqtt_consumer插件默认不会强制锁定MQTT v3.1.1，必须显式添加protocol_version = "3.1.1"参数，否则会因协议版本协商不匹配被OneNet拒绝。

2. Telegraf v1.34.2是否支持MQTT v3.1.1，是否需要升级版本？ #

Telegraf v1.34.2完全支持MQTT v3.1.1，无需升级。该版本的mqtt_consumer插件兼容MQTT v3.1、v3.1.1和v5.0，问题根源是未指定协议版本，而非版本兼容性问题。

3. 还有哪些排查步骤可解决该问题？ #

• 验证配置语法：执行telegraf --config your_config.conf --test命令，检查配置文件是否存在语法错误，确保配置能正常加载；
• 第三方工具测试连接：用MQTTX、Mosquitto等客户端工具，使用相同的client_id、username、password连接OneNet，测试能否正常订阅指定topic，排除OneNet端权限或账号问题；
• 检查网络连通性：在Telegraf所在主机执行telnet mqtt.heclouds.com 1883或nc -zv mqtt.heclouds.com 1883，确认端口是否可访问，排查防火墙/安全组拦截问题；
• 启用Debug日志：在配置的[agent]段添加debug = true，重启后查看详细的MQTT握手日志，确认协议协商、认证过程中的具体错误；
• 检查OneNet设备权限：确认对应client_id的设备拥有订阅$sys开头topic的权限，OneNet部分系统topic需额外配置权限；
• 修正地址端口匹配：mqtts.heclouds.com是SSL加密地址，对应端口应为8883；1883是明文端口，对应地址应为mqtt.heclouds.com，不要混淆两者。

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