From a64e84434984e1ed2c5abbf7f7d51289281ec7af Mon Sep 17 00:00:00 2001
From: hxy7yx <1595670487@qq.com>
Date: Fri, 6 Sep 2024 13:50:03 +0800
Subject: [PATCH] MQTT default version v5

---
 plugins/mqtt/azure_iot_plugin.c | 1 +
 plugins/mqtt/mqtt_config.c      | 2 +-
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/plugins/mqtt/azure_iot_plugin.c b/plugins/mqtt/azure_iot_plugin.c
index 5fe05db4..3aa17b66 100644
--- a/plugins/mqtt/azure_iot_plugin.c
+++ b/plugins/mqtt/azure_iot_plugin.c
@@ -198,6 +198,7 @@ static int azure_parse_config(neu_plugin_t *plugin, const char *setting,
     config->cert                = cert.v.val_str;
     config->key                 = key.v.val_str;
 
+    plog_notice(plugin, "config MQTT version    : %d", config->version);
     plog_notice(plugin, "config client-id       : %s", config->client_id);
     plog_notice(plugin, "config qos             : %d", config->qos);
     plog_notice(plugin, "config format          : %s",
diff --git a/plugins/mqtt/mqtt_config.c b/plugins/mqtt/mqtt_config.c
index a8156bdb..6a9ced31 100644
--- a/plugins/mqtt/mqtt_config.c
+++ b/plugins/mqtt/mqtt_config.c
@@ -221,7 +221,7 @@ int mqtt_config_parse(neu_plugin_t *plugin, const char *setting,
     neu_json_elem_t version = {
         .name      = "version",
         .t         = NEU_JSON_INT,
-        .v.val_int = NEU_MQTT_VERSION_V311,         // default to V311
+        .v.val_int = NEU_MQTT_VERSION_V5,         // default to V5
         .attribute = NEU_JSON_ATTRIBUTE_OPTIONAL, // for backward compatibility
     };
     neu_json_elem_t client_id = { .name = "client-id", .t = NEU_JSON_STR };