mop
mop copied to clipboard
MQTT on Pulsar implemented using Pulsar Protocol Handler
**Describe the bug** When i created a pulsar topic using mop and when trying to consume that topic it consumes only till the last stored data and not the new...
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.
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.
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.
This is a PR created by snbot to trigger the check suite in each repository.
**Describe the bug** When bridging another MQTT with MOP, I'm getting the following error. ``` 2024-07-11T20:21:17,698+0000 [mqtt-redirect-io-46-5] ERROR io.streamnative.pulsar.handlers.mqtt.MQTTCommonInboundHandler - Exception was caught while processing MQTT message, java.lang.IllegalStateException: MQTT is...