From 249c4c1c799584090bccc64fc596c883c9dbeb1a Mon Sep 17 00:00:00 2001
From: "Zaiming (Stone) Shi" <zmstone@gmail.com>
Date: Thu, 12 Jan 2023 18:26:38 +0100
Subject: [PATCH] refactor: use 'bufs' for resource worker replayq dir

---
 apps/emqx_resource/src/emqx_resource_worker.erl | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/apps/emqx_resource/src/emqx_resource_worker.erl b/apps/emqx_resource/src/emqx_resource_worker.erl
index 5edee241f..d301ce03c 100644
--- a/apps/emqx_resource/src/emqx_resource_worker.erl
+++ b/apps/emqx_resource/src/emqx_resource_worker.erl
@@ -1021,7 +1021,7 @@ queue_count(Q) ->
 disk_queue_dir(Id, Index) ->
     QDir0 = binary_to_list(Id) ++ "_" ++ integer_to_list(Index),
     QDir = sanitizy_file_path(QDir0),
-    filename:join([emqx:data_dir(), "resource_worker", node(), QDir]).
+    filename:join([emqx:data_dir(), "bufs", node(), QDir]).
 
 sanitizy_file_path(Filepath) ->
     iolist_to_binary(string:replace(Filepath, ":", "_", all)).