fix(mria): Strictly check compatibility of the replicant with core

apps/emqx/rebar.config

@@ -28,7 +28,7 @@
     {gproc, {git, "https://github.com/emqx/gproc", {tag, "0.9.0.1"}}},
     {cowboy, {git, "https://github.com/emqx/cowboy", {tag, "2.9.2"}}},
     {esockd, {git, "https://github.com/emqx/esockd", {tag, "5.11.1"}}},
-    {ekka, {git, "https://github.com/emqx/ekka", {tag, "0.19.0"}}},
+    {ekka, {git, "https://github.com/emqx/ekka", {branch, "dev/custom-core-compat-cb"}}},
     {gen_rpc, {git, "https://github.com/emqx/gen_rpc", {tag, "3.3.1"}}},
     {hocon, {git, "https://github.com/emqx/hocon.git", {tag, "0.42.1"}}},
     {emqx_http_lib, {git, "https://github.com/emqx/emqx_http_lib.git", {tag, "0.5.3"}}},

apps/emqx_machine/src/emqx_machine.erl

@@ -51,6 +51,26 @@ start() ->
     configure_shard_transports(),
     set_mnesia_extra_diagnostic_checks(),
     emqx_otel_app:configure_otel_deps(),
+    %% Register mria callbacks that help to check compatibility of the
+    %% replicant with the core node. Currently they rely on the exact
+    %% match of the version of EMQX OTP application:
+    application:load(mria),
+    application:load(emqx),
+    mria_config:register_callback(
+        lb_custom_info,
+        fun() ->
+            get_emqx_vsn()
+        end
+    ),
+    mria_config:register_callback(
+        lb_custom_info_check,
+        fun
+            (undefined) ->
+                false;
+            (OtherVsn) ->
+                get_emqx_vsn() =:= OtherVsn
+        end
+    ),
     ekka:start(),
     ok.
 
@@ -227,3 +247,11 @@ resolve_dist_address_type() ->
         _ ->
             inet
     end.
+
+get_emqx_vsn() ->
+    case application:get_key(emqx, vsn) of
+        {ok, Vsn} ->
+            Vsn;
+        undefined ->
+            undefined
+    end.

changes/ce/fix-12786.en.md

@@ -0,0 +1,2 @@
+Add a strict check that prevents replicant nodes from connecting to the core nodes running with a different version of EMQX application.
+Effectively it means that during the rolling upgrades the replicant nodes can only work if there is at least one core node with the matching EMQX release.

rebar.config

@@ -83,7 +83,7 @@
     {cowboy, {git, "https://github.com/emqx/cowboy", {tag, "2.9.2"}}},
     {esockd, {git, "https://github.com/emqx/esockd", {tag, "5.11.1"}}},
     {rocksdb, {git, "https://github.com/emqx/erlang-rocksdb", {tag, "1.8.0-emqx-2"}}},
-    {ekka, {git, "https://github.com/emqx/ekka", {tag, "0.19.0"}}},
+    {ekka, {git, "https://github.com/emqx/ekka", {branch, "dev/custom-core-compat-cb"}}},
     {gen_rpc, {git, "https://github.com/emqx/gen_rpc", {tag, "3.3.1"}}},
     {grpc, {git, "https://github.com/emqx/grpc-erl", {tag, "0.6.12"}}},
     {minirest, {git, "https://github.com/emqx/minirest", {tag, "1.4.0"}}},