Zmq 源 编译和部署插件 配置 全局配置 server 覆盖默认设置 使用示例 Zmq 源 源将订阅 Zero Mq 主题以将消息导入 eKuiper。 编译和部署插件 # cd $eKuiper_src # go build -trimpath -modfile extensions.mod --buildmode=plugin...

Zmq Source Compile & deploy plugin Configuration Global configurations server Override the default settings Sample usage Zmq Source The source will subscribe to a Zero Mq ...

测试环境 测试方式 测试总结 性能数据 优化思路 优化参数 测试数据 优化前 (1.1.4版本) 混合DML场景测试 优化后 (1.1.5版本) Kafka + 混合DML场景测试 Kafka + 单表的batch insert场景测试 RocketMQ + 混合DML场景测试 RocketMQ + 单表的batch insert场景测...

相关概念 交换器类型 RabbitMQ 运转流程 生产者发送消息 消费者接收消息 消费模式 消息顺序性 消费端的确认与拒绝 消费端的确认 消费端的拒绝 生产者确认 事务机制 发送方确认（publisher confirm）机制 不可达消息何去何从 mandatory 参数 备份交换器 过期时间（TTL） 设置消息的 TTL ...

Zmq Sink Compile & deploy plugin Properties Sample usage Zmq Sink The sink will publish the result into a Zero Mq topic. Compile & deploy plugin # cd $eKuiper_src # go bu...

rbd-mq rbd-mq组件说明 运行方式 常用参数说明 rbd-mq rbd-mq组件说明 消息队列服务 运行方式 运行于Kubernetes集群内部，POD运行,由Kubernetes和Rainbond-Operator共同维护和管理 常用参数说明 kubectl edit rbdcomponents.rainbond.io rb...

Zmq Sink Compile & deploy plugin Properties Sample usage Zmq Sink The sink will publish the result into a Zero Mq topic. Compile & deploy plugin # cd $eKuiper_src # go bu...

MQ API

消息中间件 JMS JMS 相关概念 ActiveMQ ActiveMQ 的安装运行 ActiveMQ 的使用 通过 JMS 访问 ActiveMQ ActiveMQ 集群 消息中间件 消息中间件 MOM（Message Oriented Middleware）是在分布式环境中，两个或多个独立运行的系统之间，提供消息通讯作用的中介 作...

mq_attr Overview Summary Data Fields Details Field Documentation __unused mq_curmsgs mq_flags mq_maxmsg mq_msgsize mq_attr Overview Related Module...