EMQ X 消息服务器功能列表 功能说明 消息数据存储 消息桥接转发 规则引擎 编解码 EMQ X 消息服务器功能列表 完整的 MQTT V3.1/V3.1.1 及 V5.0 协议规范支持 QoS0, QoS1, QoS2 消息支持 持久会话与离线消息支持 Retained 消息支持 Last Will 消息支持 TCP/SSL 连接...

EMQ X 消息服务器功能列表 功能说明 消息数据存储 消息桥接转发 规则引擎 编解码 EMQ X 消息服务器功能列表 完整的 MQTT V3.1/V3.1.1 及 V5.0 协议规范支持 QoS0, QoS1, QoS2 消息支持 持久会话与离线消息支持 Retained 消息支持 Last Will 消息支持 TCP/SSL 连接...

Network filters Network filters Echo SNI Cluster Client TLS authentication extensions.filters.network.client_ssl_auth.v3.ClientSSLAuth Connection limit extensions.filter...

基本概念 消息 Tag 什么时候该用 Topic，什么时候该用 Tag？ Keys 队列 生产者 基本概念 在生产者一章的基本概念包括消息，Tag，Keys，队列和生产者 的介绍。 消息 RocketMQ 消息构成非常简单，如下图所示。 topic ，表示要发送的消息的主题。 body 表示消息的存储内容 properties ...

基础概念 消费者与消费组 负载均衡 消费位点 推、拉和长轮询 基础概念 消息通过生产者发送到某一个Topic，如果需要订阅该Topic并消费里面的消息的话，就要创建对应的消费者进行消费。在介绍消费者的使用方法之前，我们先介绍消费组 、消费位点 、推和拉 等概念。 消费者与消费组 消息系统的重要作用之一是削峰填谷，但比如在电商大促的场景中，如...

延迟消息发送 延时消息介绍 延时消息约束 延时消息示例代码 延迟消息发送 延时消息介绍 延迟消息发送是指消息发送到Apache RocketMQ后，并不期望立马投递这条消息，而是延迟一定时间后才投递到Consumer进行消费。 在分布式定时调度触发、任务超时处理等场景，需要实现精准、可靠的延时事件触发。使用 RocketMQ 的延时消息可以简...

EMQ X 消息服务器功能列表 功能说明 消息数据存储 消息桥接转发 规则引擎 编解码 EMQ X 消息服务器功能列表 完整的 MQTT V3.1/V3.1.1 及 V5.0 协议规范支持 QoS0, QoS1, QoS2 消息支持 持久会话与离线消息支持 Retained 消息支持 Last Will 消息支持 TCP/SSL 连接...

Ordered Message Sending Ordered Message Introduction Ordered Message Sample Code Consistency of Ordered Messages Ordered Message Sending Ordered Message Introduction Ordered...

消息过滤 应用场景 功能概述 订阅关系一致性 Tag标签过滤 SQL属性过滤 使用建议 消息过滤 消费者订阅了某个主题后，Apache RocketMQ 会将该主题中的所有消息投递给消费者。若消费者只需要关注部分消息，可通过设置过滤条件在 Apache RocketMQ 服务端进行过滤，只获取到需要关注的消息子集，避免接收到大量无效的消息。...

基本说明 环境版本 一、适配器整体结构 二、适配器配置介绍 2.1 总配置文件 application.yml adapter定义配置部分 2.2 使用远程配置(Mysql) 2.1.1 创建mysql schema 2.1.2 初始化数据 2.1.3 修改bootstrap.yml配置 三、适配器启动 3.1 启动canal-adapt...