mop
mop copied to clipboard
streamnative
MQTT on Pulsar implemented using Pulsar Protocol Handler
**Describe the bug** when i test mqtt proxy with many connections, memory leak appeared.  it seems that bytebuf.release was not be called when decode msg **To Reproduce** Steps to...
**Is your feature request related to a problem? Please describe.** Currently, In K8s environment we need to expose the MOP on broker to the LAN for clients using the MQTT...
if the connection from proxy to broker is down, it will cause many client connections to be closed
**Is your enhancement request related to a problem? Please describe.** If one thousand devices are connected to the proxy node, and the connection pool size from proxy to broker is...
**Is your enhancement request related to a problem? Please describe.** Current： when using mqtt proxy, client will send ping request to proxy , then proxy will send this request to...
Now Mop seems like support only Qos0 and Qos1. Does Mop have the plan to support Qos2 ? If has, when this feature can be supported ?
### Motivation Suppose there are 2 messages in the topic. One is consumed by consumer with packetId=1. but then broker-A crashes and broker-B owns the topic, it will send msg-2...
**Is your enhancement request related to a problem? Please describe.** Retain semantics were added, however I think it would be useful to mention the support for this and any of...
**Is your enhancement request related to a problem? Please describe.** Are there any plans to support hooks such as connected, disconnected, authenticate? **Describe the solution you'd like** In IoT application...
## Motivation Recently, we have upgraded log4j2 version, but find that MoP relies on log4j independently. For MoP relies on Pulsar, and Pulsar even has the log4j dependency. We need...
Metadata
Owner
Metadata
MQTT on Pulsar implemented using Pulsar Protocol Handler