/pulsar-mop-demo

An self-contained MQTT environment and application in Apache Pulsar

Primary LanguageJavaApache License 2.0Apache-2.0

MQTT on Pulsar Demo

This project allows you to quickly create a Pulsar cluster that have the AoP protocol handler preconfigured to run inside a Docker container. It also includes a simple Java code example that interacts with Apache Pulsar using MQTT.

Prerequisites

These scripts assume that you have the following development tools available in your $PATH. If this is NOT the case, please install them before attempting to use the provided shell scripts.

  • Apache Maven
  • A JDK version 11 or greater
  • Docker Desktop

Getting Started

The project includes two bash scripts that automate the demonstration process. Therefore, the first step is to make them executable by changing the permissions using the following command: chmod a+x *.sh

  • The setup.sh script must be run first, to complete the following steps:

    1. Creates the Docker image and tags it as apachepulsar/pulsar-mop
    2. Starts a Docker container based on the image that runs a Pulsar cluster in standalone mode with an MQTT port opened on port 1883

  • The test.sh script can then be run to confirm the MQTT functionality of Pulsar

    1. Builds an executable JAR file from the projects java code
    2. Runs the executable JAR file to publish and consumer data over Pulsar's MQTT port