Push消费 集群模式和广播模式 并发消费和顺序消费 消息过滤 Tag过滤 SQL92过滤 消息重试和死信队列 消息重试 死信队列 Push消费 RocketMQ Push消费的示例代码如下 public class Consumer { public static void main ( String...

http-logger skywalking-logger tcp-logger kafka-logger rocketmq-logger udp-logger clickhouse-logger syslog log-rotate error-log-logger sls-logger google-cloud-logging sp...

http-logger skywalking-logger tcp-logger kafka-logger rocketmq-logger udp-logger clickhouse-logger syslog log-rotate error-log-logger sls-logger google-cloud-logging sp...

Aliyun Sls日志插件 Logging-ElasticSearch插件 Logging-ElasticSearch插件 Logging-Kafka插件 Logging插件 Logging-Pulsar插件 Logging-RocketMQ插件 Logging-Tencent cls日志插件 Metrics插件

桥接插件列表 桥接插件列表 存储插件 配置文件 说明 emqx_bridge_kafka emqx_bridge_kafka.conf Kafka 消息队列 emqx_bridge_rabbit emqx_bridge_rabbit.conf RabbitMQ 消息队列 emqx_bridge_pulsar emqx_bridge_pulsar.co...

3.4.3 版本 3.4.3 版本 发布日期: 2019-10-28 规则引擎 RocketMQ 支持主题模板 修复热配置引起的配置文件失效 优化了规则引擎中 JSON Payload 的解析语句

架构设计 1 技术架构 2 部署架构 RocketMQ 网络部署特点 架构设计 1 技术架构 RocketMQ架构上主要分为四部分，如上图所示: Producer：消息发布的角色，支持分布式集群方式部署。Producer通过MQ的负载均衡模块选择相应的Broker集群队列进行消息投递，投递的过程支持快速失败并且低延迟。 Co...

Plugin Metadata 摘要 描述 配置示例 相关资源 Plugin Metadata 摘要 在本文档中，您将了解到 APISIX 中，插件元数据的基本概念和您可能使用到的场景。 浏览文档末尾的相关资源，获取与此相关的更多信息。 描述 在 APISIX 中，配置通用的元数据属性，可以作用于包含该元数据插件的所有路由及服务中。例如...

消费重试 应用场景 应用目的 消费重试策略概述 PushConsumer消费重试策略 SimpleConsumer消费重试策略 使用建议 消费重试 消费者出现异常，消费某条消息失败时， Apache RocketMQ 会根据消费重试策略重新投递该消息进行故障恢复。本文介绍消费重试机制的原理、版本兼容性和使用建议。 应用场景 Apache...

4 NameServer 4 NameServer ​RocketMQ 中，Name Servers 被设计用来做简单的路由管理。其职责包括： Brokers 定期向每个名称服务器注册路由数据。 名称服务器为客户端，包括生产者，消费者和命令行客户端提供最新的路由信息。 ​​