EMQ X 到 Kafka 的桥接（企业版） 场景描述 配置 Zookeeper 配置Kafka 创建topic 配置 EMQ X 企业版的Kafka Bridge 测试 测试kafka的message主题 测试kafka的session主题 EMQ X 到 Kafka 的桥接（企业版） EMQ X 节点可以桥接到流式数据处理。...

Cassandra 数据存储 安装与验证 Cassandra 服务器 配置 EMQ X 服务器 keyspace 初始化 通过命令行启动 通过管理控制台启动 客户端在线状态存储 数据表 配置项 使用示例 客户端代理订阅 数据表 配置项 使用示例 持久化发布消息 数据表 配置项 使用示例 Retain 消息持久化 表结构 配...

架构设计 (Design) 前言 100万连接 全异步架构 消息持久化 NetSplit问题 系统架构 概念模型 设计原则 系统分层 连接层设计 会话层设计 消息队列与飞行窗口 报文 ID 与消息 ID 路由层设计 分布层设计 认证与访问控制设计 认证扩展模块 访问控制(ACL) 钩子(Hook)设计 钩子(Hook)定义...

5 分钟快速入门 5 分钟快速入门 从 https://hub.docker.com/r/emqx/kuiper/tags 拉取 Kuiper 的 Docker 镜像。在本教程中推荐使用 alpine 镜像（参考 Kuiper Docker (opens new window) 的内容了解不同 Kuiper Docker 镜像的区别）。 ...

2.1.0 版本 2.1.0 版本 发布日期: 2017-04-07 The stable release of 2.1 version. Trouble with auth.mysql.acl_query (emq-auth-mysql#38) Filter the empty fields in ACL table (emq-auth-my...

2.0.2 版本 2.0.2 版本 发布日期: 2016-12-05 emqttd#787: Stop plugins before the broker stopped, clean routes when a node down emqttd#790: Unable to start emqttd service if username/pa...

命令行接口 命令行接口 EMQ X 提供了 ./bin/emqx_ctl 的管理命令行，用于用户对 EMQ X 进行管理、配置、查询。

LwM2M 协议插件 配置 LwM2M 插件 LwM2M 协议插件 emqx_lwm2m (opens new window) 提供对 LwM2M 协议的支持。 配置 LwM2M 插件 etc/plugins/emqx_lwm2m.conf: ## LwM2M 监听端口 lwm2m . port = 5683 ## L...

消息重传 基础配置 协议规范与设计 重传的对象 QoS 1 QoS 2 飞行窗口与最大接收值 消息顺序 相关配置 消息重传 消息重传 (Message Retransmission) 是属于 MQTT 协议标准规范的一部分。 协议中规定了作为通信的双方 服务端 和 客户端 对于自己发送到对端的 PUBLISH 消息都应满足其 服...

消息重传 基础配置 协议规范与设计 重传的对象 QoS 1 QoS 2 飞行窗口与最大接收值 消息顺序 相关配置 消息重传 消息重传 (Message Retransmission) 是属于 MQTT 协议标准规范的一部分。 协议中规定了作为通信的双方 服务端 和 客户端 对于自己发送到对端的 PUBLISH 消息都应满足其 服...