What's your mop version? I tested mop master of version and it's working.

1. mqtt client subscribe topic persisten://public/default/helloworld3 and persisten://public/default/helloworld3/#
2. pulsar client send message to topic persisten://public/default/helloworld3
3. all client of mqtt can receive message.

from mop.

mqtt client subscribe topic persisten://public/default/my-topic/# and persisten://public/default/my/+/topic and persisten://public/default/my/topic Report all errors

Sign Will disconnect

eroro:
Connected
reconnectHandler
Connect lost: read tcp 192.168.153.106:50020->192.168.146.17:5682: read: connection reset by peer
Connected
Connect lost: EOF
reconnectHandler
Connected
reconnectHandler
Connect lost: EOF
Connected

code:
"github.com/eclipse/paho.mqtt.golang"
func pulsar_mqtt() {
var broker = "192.168.146.17"
var port = 5682
opts := mqtt.NewClientOptions()
opts.AddBroker(fmt.Sprintf("tcp://%s:%d", broker, port))
opts.SetClientID("go_mqtt_client")
opts.SetUsername("aaaaaa")
opts.SetPassword("eyJhbGciOiJPKmv_nYeo")
opts.SetDefaultPublishHandler(messagePubHandler)
//opts.SetKeepAlive(30 * time.Second)
opts.SetAutoReconnect(true)
// ConnectRetry=true, 这个参数,初始化连接时,会自动重连,等待, 不会打印(panic(token.Error()))导致程序退出,
opts.SetConnectRetry(true)
//opts.SetCleanSession(true)
//opts.SetConnectRetryInterval(5 * time.Second)
//opts.SetMaxReconnectInterval(5 * time.Second)

opts.SetWill("persistent://public/default/my-topic", "abc123456", 1, false)
opts.OnConnect = connectHandler
opts.OnConnectionLost = connectLostHandler
opts.SetReconnectingHandler(reconnectHandler)
client := mqtt.NewClient(opts)
if token := client.Connect(); token.Wait() && token.Error() != nil {
	fmt.Println("aaaaaa")
	panic(token.Error())
}
sub(client)

select {

}

}
func sub(client mqtt.Client) {
topic := "persisten://public/default/my-topic/#"
token := client.Subscribe(topic, 1, nil)
token.Wait()
fmt.Printf("===Subscribed to topic: %s\n", topic)
}

from mop.

hi, I found that using the mqtt protocol of golang cannot receive the data sent by the pulsar protocol, the package github.com/eclipse/paho.mqtt.golang is used, but the data sent by the pulsar protocol can be received using the mqtt protocol of java, java Bag:

org.fusesource.mqtt-client
mqtt-client
1.16

or

org.springframework.integration
spring-integration-mqtt
5.3.4.RELEASE

Java subscribed topic: persisten://public/default/my-topic/# and persisten://public/default/my/+/topic and persisten://public/default/my/topic This topic does not report an error, But can't subscribe to data

from mop.

I will test again,

1. golang mqtt producer send message and java mqtt client subscribe
2. golang pulsar producer send message and java mqtt client subscribe

from mop.

After talking with the author, the issue has been fixed. So close it.

from mop.