java连接emqx设置禁止本地转发异常

[chenhao]

我在java中使用org.eclipse.paho.mqttv5.client.MqttClient库连接emqx（emqx版本为5.8.4开源版），我想在订阅时设置禁止本地转发，因此我在代码中做了如下设置：

然后在连接时就出现了如下错误：

，如果我把mqttSubscription.setNoLocal(true);这一行去掉就不会报错，请问为什么会出现这个报错呢？

[zhongwencool]

设置Mqtt 的版本是5 不要设成3.1，

[chenhao]

我看默认就是v5了

[zhongwencool]

开 emqx 的 debug 日志看看

[chenhao]

已解决，是因为我同时使用了共享订阅导致的