{"repo":"streamnative/mop","free":true,"listed":false,"github":"https://github.com/streamnative/mop","clone":"git clone https://github.com/streamnative/mop.git","description":"MQTT on Pulsar implemented using Pulsar Protocol Handler","language":"Java","stars":190,"topics":["apache-pulsar","mqtt","mqtt-broker","protocol-handler","mop","messaging","iot","pulsar"],"license":"Apache-2.0","category":"chat-messaging","readme_excerpt":"MQTT on Pulsar (MoP) MQTT-on-Pulsar (aka MoP) is developed to support MQTT protocol natively on Apache Pulsar. Get started Download or build MoP protocol handler 1. Clone the MoP project from GitHub to your local. 2. Build the project. 3. The NAR file can be found at this location. Install MoP protocol handler Configure the Pulsar broker to run the MoP protocol handler as a plugin by adding configurations to the Pulsar configuration file, such as broker.conf or standalone.conf . 1. Set the configuration of the MoP protocol handler. Add the following properties and set their values in the Pulsar configuration file, such as conf/broker.conf or conf/standalone.conf . Property Suggested value Default value --- --- --- messagingProtocols mqtt null protocolHandlerDirectory Location of MoP NAR file ./protocols Example 2. Set the MQTT server listeners. Example #### Note The default hostname of advertisedAddress is InetAddress.getLocalHost().getHostName(). If you'd like to config this, please keep the same as Pulsar broker's advertisedAddress . Load MoP protocol handler After you install the MoP protocol handler to Pulsar broker, you can restart the Pulsar brokers to load the MoP protocol handler. How to use Proxy To use the proxy, follow the following steps. For detailed steps, refer to Deploy a cluster on bare metal. 1. Prepare a ZooKeeper cluster. 2. Initialize the cluster metadata. 3. Prepare a BookKeeper cluster. 4. Copy the pulsar-protocol-handler-mqtt-${version}.nar to the $PUL","default_branch":null,"files":null,"tree":[],"storefront":"/r/streamnative","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/streamnative/mop/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}