Skip to content

EMQX Enterprise Docs

Main Navigationemqx.com

v5.6

v5.5

v5.4

v5.3

v5.2

v5.1

v5.0

v4.4

v4.3

v4.2

v4.1

v4.0

v3.0

v2.0

v1.0

English

English

Appearance

Sidebar Navigation

EMQX Enterprise Overview

What's New

Get Started

Operating Limitations

FAQ

Technical Support

Product Roadmap

Installation and Migration

Deploy

Debian

Ubuntu

CentOS/RHEL

macOS

Kubernetes

Work with License

Upgrade Guide

Rolling Upgrade

Upgrade EMQX Cluster from 4.4 to 5.1

Upgrade EMQX on Kubernetes

Developer Guide

Publish/Subscribe

MQTT Core Concepts

Test with MQTT Clients

MQTT Shared Subscription

MQTT Retained Message

MQTT Will Message

Exclusive Subscription

Delayed Publish

Auto Subscribe

Topic Rewrite

Wildcard Subscription

Client SDK

Connect via C SDK

Connect via Java SDK

Connect via Go SDK

Connect via Python SDK

Connect via JavaScript SDK

REST API

API Docs

EMQX Clustering

Architecture

Create and Manage Cluster

Cluster Security

Configure Load Balancer

Load Balance EMQX Cluster with NGINX

Load Balance EMQX Cluster with HAProxy

Node Evacuation and Cluster Load Rebalancing

Performance and Tuning

Performance Tuning (Linux)

Performance Test with eMQTT-Bench

Performance Test with XMeter Cloud

Test Scenarios and Results for Reference

Security Guide

Network and TLS

Enable SSL/TLS Connection

Client TLS Connection Code Examples

Obtain SSL/TLS Certificates

CRL Check

OCSP Stapling

Authentication

X.509 Certificate Authentication

JWT Authentication

Password-Based Authentication

Use Built-in Database

Integrate with MySQL

Integrate with MongoDB

Integrate with PostgreSQL

Integrate with Redis

Integrate with LDAP

Use HTTP Service

MQTT 5.0 Enhanced Authentication

PSK Authentication

Use HTTP API to Manage User Data

Authorization

Use ACL File

Use Built-in Database

Integrate with MySQL

Integrate with MongoDB

Integrate with PostgreSQL

Integrate with Redis

Integrate with LDAP

Use HTTP Service

Banned Clients

Flapping Detect

Rule Engine

Create Rules

Rule SQL Reference

Data Sources and Fields

Built-in SQL Functions

jq Functions

Schema Registry

Schema Registry Example - Avro

Schema Registry Example - Protobuf

Sparkplug

Flow Designer

Data Integration

Connector

Webhook

Apache Kafka

Apache IoTDB

Apache Pulsar

AWS Kinesis

AWS S3

Azure Event Hubs

Cassandra

ClickHouse

Confluent

DynamoDB

Elasticsearch

GCP PubSub

GreptimeDB

HStreamDB

HTTP Server

InfluxDB

Microsoft SQL Server

MongoDB

MQTT

MySQL

OpenTSDB

Oracle Database

PostgreSQL

RabbitMQ

Redis

RocketMQ

SysKeeper

TDengine

TimescaleDB

Administration Guide

Configuration

Cluster

Listener

MQTT

Flapping Detection

Limiter

Logs

Prometheus

Dashboard

License

Configuration Manual

Command Line Interface

EMQX Dashboard

Dashboard Home Page

Connections

Topics and subscription

Topics

Subscriptions

Retained Messages

Access Control

Authentication

Authorization

Banned Clients

Data Integration

Flows

Rules

Data Bridge

Management

Extensions

Diagnose

System

Single Sign-On (SSO)

Configure OpenLDAP and Microsoft Entra ID SSO

Configure SAML-Based SSO

Audit Log

Rate Limit

Logs and Observability

Statistics and Metrics

Alarm

Logs

Topic Metrics

Slow Subscriptions

Log Trace

System Topic

Integrate with Prometheus

Integrate with OpenTelemetry

Metrics

Logs

Traces

Backup and Restore

Plugin and Extension

Hooks

Plugins

gRPC Hook Extension

Advanced Features

MQTT over QUIC

Features and Benefits

Use MQTT over QUIC

File Transfer over MQTT

Quick Start with MQTT File Transfer

Configure File Transfer Server-Side Settings

File Transfer Clients Development

Multi-Protocol Gateway

STOMP Gateway

MQTT-SN Gateway

CoAP Gateway

LwM2M Gateway

ExProto Gateway

OCPP Gateway

JT/T 808 Gateway

JT/T 808 Gateway Data Exchange Format

GB/T 32960 Gateway

Tutorials

MQTT Programming

EMQX Essentials

MQTT Guide

Design and Implementation

Clustering

In-flight and Message Queue

Message Retransmission

Reference

MQTT 5.0 Specification

MQTT 3.1.1 Specification

MQTT Glossary

MQTT 5.0 Features

MQTT Reason Code

Release Notes

Version 5

Version 4

Incompatible Changes

Incompatible Changes in EMQX 5.6

Incompatible Changes in EMQX 5.5

Incompatible Changes in EMQX 5.4

Incompatible Changes between EMQX 4.4 and EMQX 5.1

Authentication / Authorization Incompatibility Between EMQX 4.4 and EMQX 5.1

Data Integration Incompatibility Between EMQX 5.1 and EMQX 4.4

Gateway Incompatibility Between EMQX 4.4 and EMQX 5.1

End of Life Dates

Report docs issues Edit this page

On this page

Table of Contents for current page

Data Integration

This chapter will introduce how to integrate different data systems with EMQX Dashboard:

Data Bridge
Rules
Flows

Previous pageBanned Clients

© 2013-2025 EMQ Technologies Inc. All rights reserved