From 2d4baeb100ddd9bc83ffa6a70bb34777cfc57f49 Mon Sep 17 00:00:00 2001
From: fengzero <fengzero@fengzero.com>
Date: Tue, 17 Mar 2026 01:56:00 +0000
Subject: [PATCH] rm mqtt db cache

---
 plugins/mqtt/mqtt_plugin_intf.c | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/plugins/mqtt/mqtt_plugin_intf.c b/plugins/mqtt/mqtt_plugin_intf.c
index e29fce07..52db178f 100644
--- a/plugins/mqtt/mqtt_plugin_intf.c
+++ b/plugins/mqtt/mqtt_plugin_intf.c
@@ -167,6 +167,7 @@ int mqtt_plugin_uninit(neu_plugin_t *plugin)
 
     mqtt_config_fini(&plugin->config);
     if (plugin->client) {
+        neu_mqtt_client_remove_cache_db(plugin->client);
         neu_mqtt_client_close(plugin->client);
         neu_mqtt_client_free(plugin->client);
         plugin->client = NULL;
@@ -341,6 +342,7 @@ int mqtt_plugin_config(neu_plugin_t *plugin, const char *setting)
     }
 
     if (plugin->client != NULL) {
+        neu_mqtt_client_remove_cache_db(plugin->client);
         if (neu_mqtt_client_is_open(plugin->client)) {
             neu_mqtt_client_close(plugin->client);
         }