Data Integration

Data integration is a channel used to connect EMQX and external data systems, for example, databases like MySQL, MongoDB, message brokers like Apache Kafka and RabbitMQ, or even an HTTP server.

Through data integration, users can send messages from EMQX to the external data system in real-time, or pull data from the external data system and send it to a topic in EMQX.

This chapter introduces the supported external data systems, how to set up the data bridge, how to create a rule for data forwarding, and how to test the data bridge and rules you just created.

Currently, the following are supported:

• Bridge Data into MQTT Broker
• MQTT Subscriber
• Steam Data into Kafka
• Kafka Consumer
• Ingest Data into InfluxDB
• Ingest Data into InfluxDB V2
• Ingest Data into MySQL
• Ingest Data into PostgreSQL
• Ingest Data into Redis
• Ingest Data into MongoDB
• Steam Data into HStreamDB
• Ingest Data into Pulsar
• Pulsar Consumer
• Ingest Data into RabbitMQ
• Ingest Data into RocketMQ
• Ingest Data into DynamoDB
• Ingest Data into TDengine
• Ingest Data into TimescaleDB
• Ingest Data into OpenTSDB
• Ingest Data into DolphinDB
• Ingest Data into ClickHouse
• Ingest Data into Cassandra
• Ingest Data into Oracle DB
• Ingest Data into Microsoft SQL Server
• Bridge Data into Multiple MQTT Brokers