Tool Relations

n8n workflows can write to InfluxDB via HTTP API calls, acting as a transformation and routing layer between MQTT/webhook event sources and time-series storage.

EMQX

→

InfluxDB

Integrates with

EMQX provides native InfluxDB integration, enabling direct storage of MQTT message data into InfluxDB time-series database for IoT analytics and monitoring.

HiveMQ brokers MQTT messages from IoT devices that are then written to InfluxDB for time-series storage and analysis.

Telegraf writes collected metrics to InfluxDB via native Line Protocol support

Confluent Platform integrates with InfluxDB through Kafka Connect sink connectors, enabling real-time streaming of sensor and event data into time-series storage.

RabbitMQ can feed time-series data to InfluxDB through consumer applications or middleware like Telegraf, enabling IoT data pipelines.

Apache Flink can write processed time-series data to InfluxDB via JDBC connector or custom sinks, enabling real-time storage and visualization of industrial metrics.

Eclipse Kapua can forward device telemetry to InfluxDB for time-series storage and analytics. This combination enables long-term data retention and powerful querying capabilities.

NATS and InfluxDB form a powerful combination for real-time time-series data collection and storage in IIoT deployments.

Pulsar can stream high-throughput IoT and event data into InfluxDB for time-series storage and analysis.

Kafka can stream high-throughput IoT sensor data into InfluxDB for time-series storage and analysis.

Eclipse Hono normalizes telemetry from IoT devices and forwards it to downstream consumers. InfluxDB is a common destination for time-series telemetry data ingested through Hono pipelines.

Mosquitto publishes MQTT messages that Telegraf (InfluxData's collection agent, part of the InfluxDB ecosystem) subscribes to and writes into InfluxDB. Telegraf acts as the bridge — it's a standalone agent from InfluxData that collects metrics from 300+ sources, including MQTT brokers, and writes them to InfluxDB. This Mosquitto → Telegraf → InfluxDB pipeline is the data ingestion path in the MING stack.