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

meiQia 论坛示例 概述 Appkey获取方法 多个账户聊天记录重复一样的解决办法 开源地址 initMeiQia params 示例代码 补充说明 可用性 setTitleColor params 示例代码 可用性 setTitleBarColor params 示例代码 可用性 show params 示例代码...

Zmq 目标（Sink） 编译和部署插件 属性 使用示例 Zmq 目标（Sink） 目标（Sink）会将结果发布到 Zero Mq 主题中。 编译和部署插件 # cd $ekuiper_src # go build -trimpath -modfile extensions.mod --buildmode=plugin -o plugin...

基本介绍 示例1，使用标准库信号监听 示例2，使用gproc 信号监听 基本介绍 gproc 组件提供了统一的信号监听和回调处理功能，目的是解决在程序中多个不同组件冗余的信号处理逻辑，以及接收退出信号后无法平滑析构的痛点。在没有统一退出信号监听的组件下，当多个组件通过goroutine 异步监听信号，主goroutine 接收到退出信号往往会直接退...

基本介绍 示例1，使用标准库信号监听 示例2，使用gproc 信号监听 基本介绍 gproc 组件提供了统一的信号监听和回调处理功能，目的是解决在程序中多个不同组件冗余的信号处理逻辑，以及接收退出信号后无法平滑析构的痛点。在没有统一退出信号监听的组件下，当多个组件通过goroutine 异步监听信号，主goroutine 接收到退出信号往往会直接退...

基本介绍 示例1，使用标准库信号监听 示例2，使用gproc 信号监听 基本介绍 gproc 组件提供了统一的信号监听和回调处理功能，目的是解决在程序中多个不同组件冗余的信号处理逻辑，以及接收退出信号后无法平滑析构的痛点。在没有统一退出信号监听的组件下，当多个组件通过goroutine 异步监听信号，主goroutine 接收到退出信号往往会直接退...

参数配置 基本配置（ common.properties ） 日志输出配置（ log4j2.xml ） 其他自动更新配置 source-channel-sink 管道配置（dataproxy-{tube|pulsar}.conf） 参数配置 基本配置（ common.properties ） 参数 描述 默认值 备注 manager.host...

参数配置 基本配置（ common.properties ） 日志输出配置（ log4j2.xml ） 其他自动更新配置 source-channel-sink 管道配置（dataproxy-{tube|pulsar}.conf） 参数配置 基本配置（ common.properties ） 参数 描述 默认值 备注 manager.host...

参数配置 基本配置（ common.properties ） 日志输出配置（ log4j2.xml ） 其他自动更新配置 source-channel-sink 管道配置（dataproxy-{tube|pulsar}.conf） 参数配置 基本配置（ common.properties ） 参数 描述 默认值 备注 manager.host...

MQ MQ使用场景 MQ缺点 MQ常用协议 MQ的通讯模式 消息投递保证 参考链接 MQ 消息队列技术(Message Queue) 是分布式应用间交换信息的一种技术。消息队列可驻留在内存或磁盘上, 队列存储消息直到它们被应用程序读走。通过消息队列，应用程序可独立地执行 ———— 它们不需要知道彼此的位置、或在继续执行前不需要等待接收程序...