mop
mop copied to clipboard
MQTT on Pulsar implemented using Pulsar Protocol Handler
step1: Mop service built using MQTT client connection. step2: The client waits for 2 seconds and prompts Broker connection loss: Resting client.  
**Describe the bug** Shared subscriptions still don't seem to be supported by current MOPs, like `$share/group1/persistent://public/default/a/#`. Shared subscription link: https://www.emqx.com/zh/blog/introduction-to-mqtt5-protocol-shared-subscription **To Reproduce** Send a message using topic `a/b/c` and subsribe...
``` Error: Tests run: 51, Failures: 2, Errors: 0, Skipped: 0, Time elapsed: 339.788 s
Hi Streamnative team, I'm using MOP Proxy v 2.9.4.3 with pulsar v2.9.4 , I'm getting below error when trying to pub/sub to a topic : 2023-02-16T06:52:38,092-0500 [mqtt-redirect-io-57-3] INFO io.streamnative.pulsar.handlers.mqtt.support.handler.AbstractAckHandler -...
This is a PR created by snbot to trigger the check suite in each repository.
**Describe the bug** 启动pulsar报java.nio.file.NoSuchFileException: /tmp/pulsar-nar/pulsar-protocol-handler-mqtt-2.8.1.23.nar-unpacked/UdB3VJeg7mGXymmwakz1bw/META-INF/services/pulsar-protocol-handler.yml pulsar version : apache-pulsar-2.8.1 nar version: pulsar-protocol-handler-mqtt-2.8.1.23.nar
*(If this PR fixes a github issue, please add `Fixes #`.)* Fixes #332 *(or if this PR is one task of a github issue, please add `Master Issue: #` to...
This is a PR created by snbot to trigger the check suite in each repository.
This is a PR created by snbot to trigger the check suite in each repository.
*(If this PR fixes a github issue, please add `Fixes #`.)* Fixes # *(or if this PR is one task of a github issue, please add `Master Issue: #` to...