From 6cf583a301211d5d1da93be9cbec108bd1e16d8a Mon Sep 17 00:00:00 2001
From: DDDHuang <44492639+DDDHuang@users.noreply.github.com>
Date: Wed, 22 Jun 2022 11:03:34 +0800
Subject: [PATCH] fix(kafka): data backup, support old strategy style

---
 .../src/emqx_mgmt_data_backup.erl                | 16 ++++++++++++++++
 1 file changed, 16 insertions(+)

diff --git a/apps/emqx_management/src/emqx_mgmt_data_backup.erl b/apps/emqx_management/src/emqx_mgmt_data_backup.erl
index cb94b7cf9..b0d346489 100644
--- a/apps/emqx_management/src/emqx_mgmt_data_backup.erl
+++ b/apps/emqx_management/src/emqx_mgmt_data_backup.erl
@@ -206,6 +206,22 @@ import_rule(#{<<"id">> := RuleId,
 map_to_actions(Maps) ->
     [map_to_action(M) || M <- Maps].
 
+map_to_action(Map = #{<<"id">> := ActionInstId,
+                      <<"name">> := <<"data_to_kafka">>,
+                      <<"args">> := Args}) ->
+    NArgs =
+        case maps:get(<<"strategy">>, Args, undefined) of
+            <<"first_key_dispatch">> ->
+                %% Old version(4.2.x) is first_key_dispatch.
+                %% Now is key_dispatch.
+                Args#{<<"strategy">> => <<"key_dispatch">>};
+            _ ->
+                Args
+        end,
+    #{id => ActionInstId,
+      name => 'data_to_kafka',
+      args => NArgs,
+      fallbacks => map_to_actions(maps:get(<<"fallbacks">>, Map, []))};
 map_to_action(Map = #{<<"id">> := ActionInstId, <<"name">> := Name, <<"args">> := Args}) ->
     #{id => ActionInstId,
       name => any_to_atom(Name),