RocketMQ Streams 概览 整体架构 消费模型 状态 扩缩容 RocketMQ Streams 概览 RocketMQ Streams是基于RocketMQ的轻量级流计算引擎。能以SDK方式被应用依赖，无须部署复杂的流计算服务端即可获得流计算能力。 因此具有资源消耗少、扩展性好、支持流计算算子丰富的特点。 整体架构 数据从R...

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

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

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

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

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...

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...

DataProxy 插件 总览 概念和模型 数据流图示 开发流程 接口 MessageQueueHandler EventHandler 插件配置 dataproxy.conf DataProxy 插件 总览 DataProxy 实现了统一抽象 MQ (Message Queue) Sink 模型，支持在标准 MessageQueu...

DataProxy 插件扩展 总览 概念和模型 数据流图示 开发流程 接口 MessageQueueHandler EventHandler 插件配置 dataproxy.conf DataProxy 插件扩展 总览 DataProxy 实现了统一抽象 MQ (Message Queue) Sink 模型，支持在标准 Message...

RocketMQ Streams 概览 整体架构 消费模型 状态 扩缩容 RocketMQ Streams 概览 RocketMQ Streams是基于RocketMQ的轻量级流计算引擎。能以SDK方式被应用依赖，无须部署复杂的流计算服务端即可获得流计算能力。 因此具有资源消耗少、扩展性好、支持流计算算子丰富的特点。 整体架构 数据从R...