Skip to content

1. Applicable Scenarios

  • Use Pulsar as message bus/data pipeline (Multi-tenant, Namespace, Persistent Topic)
  • Write telemetry/attributes/online/offline events to Pulsar, for consumption by stream computing/lakehouse/alarm system
  • (Optional) Issue control messages via Pulsar, implementing WritePoint/Command/RPC Receipt

2. Minimal Runnable Configuration

json
{
  "connection": {
    "serviceUrl": "pulsar://127.0.0.1:6650",
    "auth": { "mode": "none" }
  },
  "uplink": {
    "enabled": true,
    "telemetry": {
      "enabled": true,
      "topic": "persistent://public/default/ng.uplink.telemetry",
      "key": "{{device_id}}",
      "payload": { "mode": "envelope_json" }
    }
  },
  "downlink": { "enabled": false }
}

Released under the Apache License 2.0.