Skip to main content
StreamNative Private Cloud supports the MQTT protocol. By enabling the MQTT protocol in your existing StreamNative cluster, you can migrate your existing MQTT applications and services to StreamNative without modifying the code.

Enable MQTT Protocol

To enable the MQTT protocol, update the PulsarBroker CR with the following configuration:
spec:
  config:
    protocolHandlers:
      mop:
        enabled: true
        proxyEnabled: true
Configuration Fields:
  • spec.config.protocolHandlers.mop.enabled: Required. Set to true to enable the MQTT protocol.
  • spec.config.protocolHandlers.mop.proxyEnabled: Optional. Set to true to enable the MQTT proxy for external access outside the Kubernetes cluster.
Alternatively, you can use Istio for external access. See Deploy Pulsar with Istio for instructions.
The operator will automatically restart the broker pods to apply the changes.