emqx 集群节点之间订阅的topic不一致

[gmgtiger510]

我们使用k8s搭建了2节点的emqx集群，发现两个集群节点之间订阅的消息不能同步。
客户端1连接到节点A，客户端2连接到节点B，客户端1正确订阅了topic，但是收不到客户端2发送到该topic上的消息

通过如下命令查看两个节点的数据库：
%% 定义一个匿名函数来遍历并打印表中的所有记录
Fun = fun() →
mnesia:foldl(
fun(Record, Acc) →
io:format(“~p~n”, [Record]),
[Record | Acc]
end,
,
emqx_route
)
end.

%% 执行事务
{atomic, Result} = mnesia:transaction(Fun).

发现，两个节点的topic路由不一致，节点B上少了节点A订阅的topic信息，导致集群节点之间无法正确同步消息。

以上问题，存在概率性。

请问，可能是什么原因？

[zhongwencool]

看你用的是什么版本，以前有这个bug，后面修复了的

[gmgtiger510]

我们用的docker 版本 emqx:5.1.6

我们也尝试过emqx:5.8.1

[zhongwencool]

EMQX 开源版 v5 版本 | EMQX文档

修复
MQTT 核心功能
#14248 修复了集群节点间偶发的连接问题，这些问题可能导致集群范围的路由表状态部分丢失。此修复确保了集群间更好的一致性和可靠性。

[gmgtiger510]

我们升级下观察看看

[gmgtiger510]

你好，我们升级到了5.8.4版本，还是出现了偶发性的节点路由不同步。
我们是在k8s里面搭建的集群，起了2个emqx集群pod节点，我们kill其中一个pod，通过k8s自动拉起2个pod，然而，会概率性出现两个节点的路由不同步，导致订阅消息丢失。

我们通过如下命令查看两个节点：
mnesia:table_info(emqx_route, size)

发现正常情况下，两个节点打印的都是2885

异常情况下，一个节点打印2885，另外一个节点打印143，相差比较多

请问，这个与k8s集群的搭建环境是否有关？

[zhongwencool]

emqx_router:topics().

[gmgtiger510]

emqx_router:topics(). 这个命令打印的内容，好像不是很全？怎么才能打印全部的topics？

[zhongwencool]

rp(emqx_router:topics()).

检查长度

length(emqx_router:topics()).

[gmgtiger510]

概率出现不一致时，emqx-0的topic如下：
rp(emqx_router:topics()).
[<<“/sys/S1200T-S/B2310408/thing/service/edge_deploy”>>,
<<“/sys/S1200I-U/45D57BFF/thing/service/edge_deploy”>>,
<<“/sys/S1200I-S/57CC4BF0/thing/service/edge_deploy”>>,
<<“/sys/S1200I-S/28E546F9/thing/service/uploadTerminalInfo”>>,
<<“/sys/S1200I-S/28E546F9/thing/service/restart”>>,
<<“/sys/S1200I-S/28E546F9/thing/service/property/set”>>,
<<“/sys/S1200I-S/28E546F9/thing/service/edge_deploy”>>,
<<“/sys/S1200I-S/28E546F9/thing/event/tsData/post_reply”>>,
<<“/sys/S1200I-S/28E546F9/thing/event/property/post_reply”>>,
<<“/sys/DT310/B0510134/thing/topo/add_reply”>>,
<<“/sys/DT310/B0510134/thing/service/uploadTerminalInfo”>>,
<<“/sys/DT310/B0510134/thing/service/restart”>>,
<<“/sys/DT310/B0510134/thing/service/property/set”>>,
<<“/sys/DT310/B0510134/thing/service/edge_deploy”>>,
<<“/sys/DT310/B0510134/thing/event/tsData/post_reply”>>,
<<“/sys/DT310/B0510134/thing/event/property/post_reply”>>,
<<“/sys/DT310/B0510093/thing/service/edge_deploy”>>,
<<“/sys/DT310/B04C0052/thing/service/uploadTerminalInfo”>>,
<<“/sys/DT310/B04C0052/thing/service/uploadNetSignalStrength”>>,
<<“/sys/DT310/B04C0052/thing/service/triggerCollectStop”>>,
<<“/sys/DT310/B04C0052/thing/service/triggerCollectStart”>>,
<<“/sys/DT310/B04C0052/thing/service/restart”>>,
<<“/sys/DT310/B04C0052/thing/service/property/set”>>,
<<“/sys/DT310/B04C0052/thing/service/edge_deploy”>>,
<<“/sys/DT310/B04C0052/thing/event/tsData/post_reply”>>,
<<“/sys/DT310/B04C0052/thing/event/triggerData/post_reply”>>,
<<“/sys/DT310/B04C0052/thing/event/property/post_reply”>>,
<<“/sys/DT300/B0510307/thing/service/uploadTerminalInfo”>>,
<<“/sys/DT300/B0510307/thing/service/uploadNetSignalStrength”>>,
<<“/sys/DT300/B0510307/thing/service/triggerCollectStop”>>,
<<“/sys/DT300/B0510307/thing/service/triggerCollectStart”>>,
<<“/sys/DT300/B0510307/thing/service/restart”>>,
<<“/sys/DT300/B0510307/thing/service/property/set”>>,
<<“/sys/DT300/B0510307/thing/service/edge_deploy”>>,
<<“/sys/DT300/B0510307/thing/event/tsData/post_reply”>>,
<<“/sys/DT300/B0510307/thing/event/triggerData/post_reply”>>,
<<“/sys/DT300/B0510307/thing/event/property/post_reply”>>,
<<“/sys/DT300/B0510141/thing/service/uploadTerminalInfo”>>,
<<“/sys/DT300/B0510141/thing/service/uploadNetSignalStrength”>>,
<<“/sys/DT300/B0510141/thing/service/triggerCollectStop”>>,
<<“/sys/DT300/B0510141/thing/service/triggerCollectStart”>>,
<<“/sys/DT300/B0510141/thing/service/restart”>>,
<<“/sys/DT300/B0510141/thing/service/property/set”>>,
<<“/sys/DT300/B0510141/thing/service/edge_deploy”>>,
<<“/sys/DT300/B0510141/thing/event/tsData/post_reply”>>,
<<“/sys/DT300/B0510141/thing/event/triggerData/post_reply”>>,
<<“/sys/DT300/B0510141/thing/event/property/post_reply”>>,
<<“/sys/DMS1200T/B2310392/thing/service/uploadTerminalInfo”>>,
<<“/sys/DMS1200T/B2310392/thing/service/uploadNetSignalStrength”>>,
<<“/sys/DMS1200T/B2310392/thing/service/triggerCollectStop”>>,
<<“/sys/DMS1200T/B2310392/thing/service/triggerCollectStart”>>,
<<“/sys/DMS1200T/B2310392/thing/service/restart”>>,
<<“/sys/DMS1200T/B2310392/thing/service/property/set”>>,
<<“/sys/DMS1200T/B2310392/thing/service/edge_deploy”>>,
<<“/sys/DMS1200T/B2310392/thing/event/tsData/post_reply”>>,
<<“/sys/DMS1200T/B2310392/thing/event/triggerData/post_reply”>>,
<<“/sys/DMS1200T/B2310392/thing/event/property/post_reply”>>,
<<“/sys/DMS1200T/B2310273/thing/service/uploadTerminalInfo”>>,
<<“/sys/DMS1200T/B2310273/thing/service/uploadNetSignalStrength”>>,
<<“/sys/DMS1200T/B2310273/thing/service/triggerCollectStop”>>,
<<“/sys/DMS1200T/B2310273/thing/service/triggerCollectStart”>>,
<<“/sys/DMS1200T/B2310273/thing/service/restart”>>,
<<“/sys/DMS1200T/B2310273/thing/service/property/set”>>,
<<“/sys/DMS1200T/B2310273/thing/service/edge_deploy”>>,
<<“/sys/DMS1200T/B2310273/thing/event/tsData/post_reply”>>,
<<“/sys/DMS1200T/B2310273/thing/event/triggerData/post_reply”>>,
<<“/sys/DMS1200T/B2310273/thing/event/property/post_reply”>>,
<<“/sys/DMS1200I/4ED377FF/thing/service/uploadTerminalInfo”>>,
<<“/sys/DMS1200I/4ED377FF/thing/service/restart”>>,
<<“/sys/DMS1200I/4ED377FF/thing/service/property/set”>>,
<<“/sys/DMS1200I/4ED377FF/thing/service/edge_deploy”>>,
<<“/sys/DMS1200I/4ED377FF/thing/event/tsData/post_reply”>>,
<<“/sys/DMS1200I/4ED377FF/thing/event/property/post_reply”>>,
<<“/sys/DMS1200I/13E51AF6/thing/service/uploadTerminalInfo”>>,
<<“/sys/DMS1200I/13E51AF6/thing/service/uploadNetSignalStrength”>>,
<<“/sys/DMS1200I/13E51AF6/thing/service/triggerCollectStop”>>,
<<“/sys/DMS1200I/13E51AF6/thing/service/triggerCollectStart”>>,
<<“/sys/DMS1200I/13E51AF6/thing/service/restart”>>,
<<“/sys/DMS1200I/13E51AF6/thing/service/property/set”>>,
<<“/sys/DMS1200I/13E51AF6/thing/service/edge_deploy”>>,
<<“/sys/DMS1200I/13E51AF6/thing/event/tsData/post_reply”>>,
<<“/sys/DMS1200I/13E51AF6/thing/event/triggerData/post_reply”>>,
<<“/sys/DMS1200I/13E51AF6/thing/event/property/post_reply”>>,
<<“/sys/DMG311/EE031811/thing/topo/add_reply”>>,
<<“/sys/DMG311/EE031811/thing/service/uploadTerminalInfo”>>,
<<“/sys/DMG311/EE031811/thing/service/uploadNetSignalStrength”>>,
<<“/sys/DMG311/EE031811/thing/service/triggerCollectStop”>>,
<<“/sys/DMG311/EE031811/thing/service/triggerCollectStart”>>,
<<“/sys/DMG311/EE031811/thing/service/restart”>>,
<<“/sys/DMG311/EE031811/thing/service/property/set”>>,
<<“/sys/DMG311/EE031811/thing/service/edge_deploy”>>,
<<“/sys/DMG311/EE031811/thing/event/tsData/post_reply”>>,
<<“/sys/DMG311/EE031811/thing/event/triggerData/post_reply”>>,
<<“/sys/DMG311/EE031811/thing/event/property/post_reply”>>,
<<“/sys/DMG2100/EE112237/thing/topo/add_reply”>>,
<<“/sys/DMG2100/EE112237/thing/service/uploadTerminalInfo”>>,
<<“/sys/DMG2100/EE112237/thing/service/uploadNetSignalStrength”>>,
<<“/sys/DMG2100/EE112237/thing/service/triggerCollectStop”>>,
<<“/sys/DMG2100/EE112237/thing/service/triggerCollectStart”>>,
<<“/sys/DMG2100/EE112237/thing/service/restart”>>,
<<“/sys/DMG2100/EE112237/thing/service/property/set”>>,
<<“/sys/DMG2100/EE112237/thing/service/edge_deploy”>>,
<<“/sys/DMG2100/EE112237/thing/event/tsData/post_reply”>>,
<<“/sys/DMG2100/EE112237/thing/event/triggerData/post_reply”>>,
<<“/sys/DMG2100/EE112237/thing/event/property/post_reply”>>,
<<“/sys/DMG210/EE112235/thing/topo/add_reply”>>,
<<“/sys/DMG210/EE112235/thing/service/uploadTerminalInfo”>>,
<<“/sys/DMG210/EE112235/thing/service/uploadNetSignalStrength”>>,
<<“/sys/DMG210/EE112235/thing/service/triggerCollectStop”>>,
<<“/sys/DMG210/EE112235/thing/service/triggerCollectStart”>>,
<<“/sys/DMG210/EE112235/thing/service/restart”>>,
<<“/sys/DMG210/EE112235/thing/service/property/set”>>,
<<“/sys/DMG210/EE112235/thing/service/edge_deploy”>>,
<<“/sys/DMG210/EE112235/thing/event/tsData/post_reply”>>,
<<“/sys/DMG210/EE112235/thing/event/triggerData/post_reply”>>,
<<“/sys/DMG210/EE112235/thing/event/property/post_reply”>>,
<<“/sys/DMG1160I/A0000046/thing/topo/add_reply”>>,
<<“/sys/DMG1160I/A0000046/thing/service/uploadTerminalInfo”>>,
<<“/sys/DMG1160I/A0000046/thing/service/restart”>>,
<<“/sys/DMG1160I/A0000046/thing/service/property/set”>>,
<<“/sys/DMG1160I/A0000046/thing/service/edge_deploy”>>,
<<“/sys/DMG1160I/A0000046/thing/event/tsData/post_reply”>>,
<<“/sys/DMG1160I/A0000046/thing/event/property/post_reply”>>,
<<“/sys/DMG1150I/A1210001/thing/service/uploadTerminalInfo”>>,
<<“/sys/DMG1150I/A1210001/thing/service/restart”>>,
<<“/sys/DMG1150I/A1210001/thing/service/property/set”>>,
<<“/sys/DMG1150I/A1210001/thing/service/edge_deploy”>>,
<<“/sys/DMG1150I/A1210001/thing/event/tsData/post_reply”>>,
<<“/sys/DMG1150I/A1210001/thing/event/property/post_reply”>>,
<<“/sys/DCUA1204/A23C0012/thing/service/uploadTerminalInfo”>>,
<<“/sys/DCUA1204/A23C0012/thing/service/setUploadLogLevel”>>,
<<“/sys/DCUA1204/A23C0012/thing/service/property/set”>>,
<<“/sys/DCUA1204/A23C0012/thing/service/largeFileCollect”>>,
<<“/sys/DCUA1204/A23C0012/thing/service/deviceRestart”>>,
<<“/sys/DCUA1204/A23C0012/thing/event/tsData/post_reply”>>,
<<“/sys/DCUA1204/A23C0012/thing/event/property/post_reply”>>,
<<“/sys/DCUA1004/A2370019/thing/service/uploadTerminalInfo”>>,
<<“/sys/DCUA1004/A2370019/thing/service/setUploadLogLevel”>>,
<<“/sys/DCUA1004/A2370019/thing/service/property/set”>>,
<<“/sys/DCUA1004/A2370019/thing/service/largeFileCollect”>>,
<<“/sys/DCUA1004/A2370019/thing/service/deviceRestart”>>,
<<“/sys/DCUA1004/A2370019/thing/event/tsData/post_reply”>>,
<<“/sys/DCUA1004/A2370019/thing/event/property/post_reply”>>,
<<“/sys/DCUA1004/3B662E6C/thing/service/uploadTerminalInfo”>>,
<<“/sys/DCUA1004/3B662E6C/thing/service/setUploadLogLevel”>>,
<<“/sys/DCUA1004/3B662E6C/thing/service/property/set”>>,
<<“/sys/DCUA1004/3B662E6C/thing/service/largeFileCollect”>>,
<<“/sys/DCUA1004/3B662E6C/thing/service/deviceRestart”>>,
<<“/sys/DCUA1004/3B662E6C/thing/event/tsData/post_reply”>>,
<<“/sys/DCUA1004/3B662E6C/thing/event/property/post_reply”>>,
<<“/sys/DCUA1004/11111111/thing/service/uploadTerminalInfo”>>,
<<“/sys/DCUA1004/11111111/thing/service/setUploadLogLevel”>>,
<<“/sys/DCUA1004/11111111/thing/service/property/set”>>,
<<“/sys/DCUA1004/11111111/thing/service/largeFileCollect”>>,
<<“/sys/DCUA1004/11111111/thing/service/deviceRestart”>>,
<<“/sys/DCUA1004/11111111/thing/event/tsData/post_reply”>>,
<<“/sys/DCUA1004/11111111/thing/event/property/post_reply”>>,
<<“/sys/DCME2204/000009EB/thing/service/uploadTerminalInfo”>>,
<<“/sys/DCME2204/000009EB/thing/service/uploadNetSignalStrength”>>,
<<“/sys/DCME2204/000009EB/thing/service/triggerCollectStop”>>,
<<“/sys/DCME2204/000009EB/thing/service/triggerCollectStart”>>,
<<“/sys/DCME2204/000009EB/thing/service/restart”>>,
<<“/sys/DCME2204/000009EB/thing/service/property/set”>>,
<<“/sys/DCME2204/000009EB/thing/service/edge_deploy”>>,
<<“/sys/DCME2204/000009EB/thing/event/tsData/post_reply”>>,
<<“/sys/DCME2204/000009EB/thing/event/triggerData/post_reply”>>,
<<“/sys/DCME2204/000009EB/thing/event/property/post_reply”>>,
<<“/sys/DCME1002/A4440044/thing/service/uploadTerminalInfo”>>,
<<“/sys/DCME1002/A4440044/thing/service/uploadNetSignalStrength”>>,
<<“/sys/DCME1002/A4440044/thing/service/triggerCollectStop”>>,
<<“/sys/DCME1002/A4440044/thing/service/triggerCollectStart”>>,
<<“/sys/DCME1002/A4440044/thing/service/restart”>>,
<<“/sys/DCME1002/A4440044/thing/service/property/set”>>,
<<“/sys/DCME1002/A4440044/thing/service/edge_deploy”>>,
<<“/sys/DCME1002/A4440044/thing/event/tsData/post_reply”>>,
<<“/sys/DCME1002/A4440044/thing/event/triggerData/post_reply”>>,
<<“/sys/DCME1002/A4440044/thing/event/property/post_reply”>>,
<<“/ota/device/upgrade/S1200I-S/28E546F9”>>,
<<“/ota/device/upgrade/DT310/B0510134”>>,
<<“/ota/device/upgrade/DT310/B04C0052”>>,
<<“/ota/device/upgrade/DT300/B0510307”>>,
<<“/ota/device/upgrade/DT300/B0510141”>>,
<<“/ota/device/upgrade/DMS1200T/B2310392”>>,
<<“/ota/device/upgrade/DMS1200T/B2310273”>>,
<<“/ota/device/upgrade/DMS1200I/4ED377FF”>>,
<<“/ota/device/upgrade/DMS1200I/13E51AF6”>>,
<<“/ota/device/upgrade/DMG311/EE031811”>>,
<<“/ota/device/upgrade/DMG2100/EE112237”>>,
<<“/ota/device/upgrade/DMG210/EE112235”>>,
<<“/ota/device/upgrade/DMG1160I/A0000046”>>,
<<“/ota/device/upgrade/DMG1150I/A1210001”>>,
<<“/ota/device/upgrade/DCUA1204/A23C0012”>>,
<<“/ota/device/upgrade/DCUA1004/A2370019”>>,
<<“/ota/device/upgrade/DCUA1004/3B662E6C”>>,
<<“/ota/device/upgrade/DCUA1004/11111111”>>,
<<“/ota/device/upgrade/DCME2204/000009EB”>>,
<<“/ota/device/upgrade/DCME1002/A4440044”>>,
<<“/ext/session/DT310/B0510134/combine/batch_login_reply”>>,
<<“/ext/session/DMG311/EE031811/combine/batch_logout_reply”>>,
<<“/ext/session/DMG311/EE031811/combine/batch_login_reply”>>,
<<“/ext/session/DMG2100/EE112237/combine/batch_logout_reply”>>,
<<“/ext/session/DMG2100/EE112237/combine/batch_login_reply”>>,
<<“/ext/session/DMG210/EE112235/combine/batch_logout_reply”>>,
<<“/ext/session/DMG210/EE112235/combine/batch_login_reply”>>,
<<“/ext/session/DMG1160I/A0000046/combine/batch_login_reply”>>,
<<“/ext/session/DMG1150I/A1210001/combine/batch_logout_reply”>>,
<<“/ext/session/DMG1150I/A1210001/combine/batch_login_reply”>>,
<<“/ext/notify/DMG1150I/A1210001”>>,
<<“/ext/error/S1200I-S/28E546F9”>>,
<<“/ext/error/EDGE-GATEWAY/EGW123456”>>,
<<“/ext/error/DT310/B0510134”>>,
<<“/ext/error/DMS1200I/4ED377FF”>>,
<<“/ext/error/DMG311/EE031811”>>,
<<“/ext/error/DMG2100/EE112237”>>,
<<“/ext/error/DMG210/EE112235”>>,
<<“/ext/error/DMG1160I/A0000046”>>,
<<“/ext/error/DMG1150I/A1210001”>>,
<<“/ext/session/+/+/combine/batch_login”>>,
<<“/ext/session/+/+/combine/batch_logout”>>,
<<“/ota/device/inform/+/+”>>,<<“/rpc-thin/+/e2c”>>,
<<“/sys/+/+/thing/event/+/post”>>,
<<“/sys/+/+/thing/event/property/batch/post”>>,
<<“/sys/+/+/thing/service/+”>>,
<<“/sys/+/+/thing/service/property/set_reply”>>,
<<“/sys/+/+/thing/task/get”>>,<<“/sys/+/+/thing/topo/add”>>,
<<“/sys/EDGE-GATEWAY/EGW123456/#”>>,
<<“$SYS/brokers/+/clients/#”>>]
ok

长度为229

另外一个节点 emqx-1的topics如下：

[<<“/sys/S1200T-S/B2310408/thing/service/edge_deploy”>>,
<<“/sys/S1200I-U/45D57BFF/thing/service/edge_deploy”>>,
<<“/sys/S1200I-S/57CC4BF0/thing/service/edge_deploy”>>,
<<“/sys/S1200I-S/28E546F9/thing/service/uploadTerminalInfo”>>,
<<“/sys/S1200I-S/28E546F9/thing/service/restart”>>,
<<“/sys/S1200I-S/28E546F9/thing/service/property/set”>>,
<<“/sys/S1200I-S/28E546F9/thing/service/edge_deploy”>>,
<<“/sys/DT300/B0510307/thing/service/restart”>>,
<<“/sys/DT300/B0510307/thing/service/property/set”>>,
<<“/sys/DT300/B0510307/thing/service/edge_deploy”>>,
<<“/sys/DT300/B0510307/thing/event/tsData/post_reply”>>,
<<“/sys/DT300/B0510307/thing/event/triggerData/post_reply”>>,
<<“/sys/DT300/B0510307/thing/event/property/post_reply”>>,
<<“/sys/DT300/B0510141/thing/service/uploadTerminalInfo”>>,
<<“/sys/DT300/B0510141/thing/service/uploadNetSignalStrength”>>,
<<“/sys/DT300/B0510141/thing/service/triggerCollectStop”>>,
<<“/sys/DT300/B0510141/thing/service/triggerCollectStart”>>,
<<“/sys/DT300/B0510141/thing/service/restart”>>,
<<“/sys/DT300/B0510141/thing/service/property/set”>>,
<<“/sys/DT300/B0510141/thing/service/edge_deploy”>>,
<<“/sys/DT300/B0510141/thing/event/tsData/post_reply”>>,
<<“/sys/DT300/B0510141/thing/event/triggerData/post_reply”>>,
<<“/sys/DT300/B0510141/thing/event/property/post_reply”>>,
<<“/sys/DMS1200T/B2310392/thing/service/uploadTerminalInfo”>>,
<<“/sys/DMS1200T/B2310392/thing/service/uploadNetSignalStrength”>>,
<<“/sys/DMS1200T/B2310392/thing/service/triggerCollectStop”>>,
<<“/sys/DMS1200T/B2310392/thing/service/triggerCollectStart”>>,
<<“/sys/DMS1200T/B2310392/thing/service/restart”>>,
<<“/sys/DMS1200T/B2310392/thing/service/property/set”>>,
<<“/sys/DMS1200T/B2310392/thing/service/edge_deploy”>>,
<<“/sys/DMS1200T/B2310392/thing/event/tsData/post_reply”>>,
<<“/sys/DMS1200T/B2310392/thing/event/triggerData/post_reply”>>,
<<“/sys/DMS1200T/B2310392/thing/event/property/post_reply”>>,
<<“/sys/DMS1200T/B2310273/thing/service/uploadTerminalInfo”>>,
<<“/sys/DMS1200T/B2310273/thing/service/uploadNetSignalStrength”>>,
<<“/sys/DMS1200I/13E51AF6/thing/service/triggerCollectStart”>>,
<<“/sys/DMS1200I/13E51AF6/thing/service/restart”>>,
<<“/sys/DMS1200I/13E51AF6/thing/service/property/set”>>,
<<“/sys/DMS1200I/13E51AF6/thing/service/edge_deploy”>>,
<<“/sys/DMS1200I/13E51AF6/thing/event/tsData/post_reply”>>,
<<“/sys/DMS1200I/13E51AF6/thing/event/triggerData/post_reply”>>,
<<“/sys/DMS1200I/13E51AF6/thing/event/property/post_reply”>>,
<<“/sys/DMG311/EE031811/thing/topo/add_reply”>>,
<<“/sys/DMG311/EE031811/thing/service/uploadTerminalInfo”>>,
<<“/sys/DMG311/EE031811/thing/service/uploadNetSignalStrength”>>,
<<“/sys/DMG311/EE031811/thing/service/triggerCollectStop”>>,
<<“/sys/DMG311/EE031811/thing/service/triggerCollectStart”>>,
<<“/sys/DMG311/EE031811/thing/service/restart”>>,
<<“/sys/DMG311/EE031811/thing/service/property/set”>>,
<<“/sys/DMG311/EE031811/thing/service/edge_deploy”>>,
<<“/sys/DMG311/EE031811/thing/event/tsData/post_reply”>>,
<<“/sys/DMG311/EE031811/thing/event/triggerData/post_reply”>>,
<<“/sys/DMG311/EE031811/thing/event/property/post_reply”>>,
<<“/sys/DMG2100/EE112237/thing/topo/add_reply”>>,
<<“/sys/DMG2100/EE112237/thing/service/uploadTerminalInfo”>>,
<<“/sys/DMG2100/EE112237/thing/service/uploadNetSignalStrength”>>,
<<“/sys/DMG2100/EE112237/thing/service/triggerCollectStop”>>,
<<“/sys/DMG2100/EE112237/thing/service/triggerCollectStart”>>,
<<“/sys/DMG2100/EE112237/thing/service/restart”>>,
<<“/sys/DMG2100/EE112237/thing/service/property/set”>>,
<<“/sys/DMG2100/EE112237/thing/service/edge_deploy”>>,
<<“/sys/DMG2100/EE112237/thing/event/tsData/post_reply”>>,
<<“/sys/DMG2100/EE112237/thing/event/triggerData/post_reply”>>,
<<“/sys/DMG2100/EE112237/thing/event/property/post_reply”>>,
<<“/sys/DMG210/EE112235/thing/topo/add_reply”>>,
<<“/sys/DMG210/EE112235/thing/service/uploadTerminalInfo”>>,
<<“/sys/DMG210/EE112235/thing/service/uploadNetSignalStrength”>>,
<<“/sys/DMG210/EE112235/thing/service/triggerCollectStop”>>,
<<“/sys/DMG210/EE112235/thing/service/triggerCollectStart”>>,
<<“/sys/DMG210/EE112235/thing/service/restart”>>,
<<“/sys/DMG210/EE112235/thing/service/property/set”>>,
<<“/sys/DMG210/EE112235/thing/service/edge_deploy”>>,
<<“/sys/DMG210/EE112235/thing/event/tsData/post_reply”>>,
<<“/sys/DMG210/EE112235/thing/event/triggerData/post_reply”>>,
<<“/sys/DMG210/EE112235/thing/event/property/post_reply”>>,
<<“/sys/DMG1160I/A0000046/thing/topo/add_reply”>>,
<<“/sys/DMG1160I/A0000046/thing/service/uploadTerminalInfo”>>,
<<“/sys/DMG1160I/A0000046/thing/service/restart”>>,
<<“/sys/DMG1160I/A0000046/thing/service/property/set”>>,
<<“/sys/DMG1160I/A0000046/thing/service/edge_deploy”>>,
<<“/sys/DMG1160I/A0000046/thing/event/tsData/post_reply”>>,
<<“/sys/DMG1160I/A0000046/thing/event/property/post_reply”>>,
<<“/sys/DMG1150I/A1210001/thing/service/uploadTerminalInfo”>>,
<<“/sys/DMG1150I/A1210001/thing/service/restart”>>,
<<“/sys/DMG1150I/A1210001/thing/service/property/set”>>,
<<“/sys/DMG1150I/A1210001/thing/service/edge_deploy”>>,
<<“/sys/DMG1150I/A1210001/thing/event/tsData/post_reply”>>,
<<“/sys/DCUA1004/3B662E6C/thing/event/tsData/post_reply”>>,
<<“/sys/DCUA1004/3B662E6C/thing/event/property/post_reply”>>,
<<“/sys/DCUA1004/11111111/thing/service/uploadTerminalInfo”>>,
<<“/sys/DCUA1004/11111111/thing/service/setUploadLogLevel”>>,
<<“/sys/DCUA1004/11111111/thing/service/property/set”>>,
<<“/sys/DCUA1004/11111111/thing/service/largeFileCollect”>>,
<<“/sys/DCUA1004/11111111/thing/service/deviceRestart”>>,
<<“/sys/DCUA1004/11111111/thing/event/tsData/post_reply”>>,
<<“/sys/DCUA1004/11111111/thing/event/property/post_reply”>>,
<<“/sys/DCME2204/000009EB/thing/service/uploadTerminalInfo”>>,
<<“/sys/DCME2204/000009EB/thing/service/uploadNetSignalStrength”>>,
<<“/sys/DCME2204/000009EB/thing/service/triggerCollectStop”>>,
<<“/sys/DCME2204/000009EB/thing/service/triggerCollectStart”>>,
<<“/ext/session/DT310/B0510134/combine/batch_login_reply”>>,
<<“/ext/session/DMG311/EE031811/combine/batch_logout_reply”>>,
<<“/ext/session/DMG311/EE031811/combine/batch_login_reply”>>,
<<“/ext/session/DMG2100/EE112237/combine/batch_logout_reply”>>,
<<“/ext/session/DMG2100/EE112237/combine/batch_login_reply”>>,
<<“/ext/session/DMG210/EE112235/combine/batch_logout_reply”>>,
<<“/ext/session/DMG210/EE112235/combine/batch_login_reply”>>,
<<“/ext/session/DMG1160I/A0000046/combine/batch_login_reply”>>,
<<“/ext/session/DMG1150I/A1210001/combine/batch_logout_reply”>>,
<<“/ext/session/DMG1150I/A1210001/combine/batch_login_reply”>>,
<<“/ext/notify/DMG1150I/A1210001”>>,
<<“/ext/error/S1200I-S/28E546F9”>>,
<<“/ext/error/EDGE-GATEWAY/EGW123456”>>,
<<“/ext/error/DT310/B0510134”>>,
<<“/ext/error/DMS1200I/4ED377FF”>>,
<<“/ext/error/DMG311/EE031811”>>,
<<“/ext/error/DMG2100/EE112237”>>,
<<“/ext/error/DMG210/EE112235”>>,
<<“/ext/error/DMG1160I/A0000046”>>,
<<“/ext/error/DMG1150I/A1210001”>>]
ok

length(emqx_router:topics()).
长度为120

概率出现多次，每次的长度会略有变化，但是两个节点的长度都不一样。

[zhongwencool]

可以在 github issue 上更新了，让他们看看，我没法了。 ：（

Inconsistency in Subscribed Topics Between EMQ X Cluster Nodes · emqx/emqx ·...