emqx版本:5.8.3
exhook实现语言:java
exhook部署:k8s部署2实例,使用svc地址访问
前提:exhook中实现onClientConnected,onClientDisconnected钩子,监听客户端上下线状态
问题:在极短时间(3ms)内触发了同一个mqtt的上下线,发现上线消息与下线消息在不同的exhook实例中处理了,导致后续发送到kafka的消息的顺序出现了错乱,上线消息先进入kafka,下线消息3ms后进入kafka;期望是下线消息先进入
因为使用了 pool(pool_size 8). 不能通过入库时间来判断,你可看消息里面的时间。
我想知道的是同一个client的上下线消息不会被负载到同一个exhook实例上来处理吗
期待同一个clientId的钩子事件在同一个exhook实例中处理,这样他就有了顺序性
        