HiveMQ TDengine Plugin

The HiveMQ TDengine Extension is a plugin that seamlessly bridges MQTT messaging with time-series data storage. It intercepts all messages published to a HiveMQ broker and persistently writes them to a TDengine database, enabling real-time IoT and telemetry data ingestion and analysis.

Key Features

• Real-time Data Ingestion — Intercepts and asynchronously writes every MQTT publish message to TDengine.
• Dual Write Methods — Supports writing data via both HTTP and native TDengine SDK connections.
• Automatic Schema Management — Creates the required database and table on startup based on configuration.
• Payload Encoding Handling — Automatically attempts Base64 encoding if the payload contains characters incompatible with GBK encoding.
• Concurrency Safety — Implements locking mechanisms to handle high-concurrency writes and avoid SDK pointer errors.

Architecture

The plugin consists of three core Java classes: TDengineExtension serves as the main entry point, managing the plugin lifecycle and configuration. TDengine handles all database connectivity, initialization, and the save operations. TDengineInterceptor is triggered on inbound publish events to call the asynchronous save method.

Philosophy

The extension is designed for simplicity and reliability, automating database setup and providing robust error handling to ensure continuous data flow from MQTT topics into structured time-series storage.