Skip to content
Fusion for Kdb+

mqtt Using MQTT with kdb+

KxSystems/mqtt

Message Queueing Telemetry Transport (MQTT) is a machine-to-machine/IOT connectivity protocol. It is designed to be lightweight, offering functionality for publish/subscribe messaging transport.

The protocol is commonly used for constrained devices with low bandwidth, high latency or on unreliable networks.

Use cases

This messaging protocol is used extensively where a small software footprint is required, e.g.

  • communication with edge devices/sensors
  • home automation
  • mobile applications

MQTT: Real-world applications

Kdb+/MQTT integration

This interface lets you communicate with an MQTT broker from a kdb+ session. The interface follows closely the PAHO MQTT C API. Exposed functionality includes

  • connect to an MQTT broker
  • subscribe to topics
  • publish to a broker

Function reference, example implementations
Install guide

To run the examples you will need a MQTT broker installed and running locally.

Status

The interface is currently available as a beta version under an Apache 2.0 license and is supported on a best-efforts basis by the Kx Fusion team. The interface is currently in active development, with additional functionality released on an ongoing basis.

Issues and feature requests

Guide to contributing