新增EMQ实时采集

本节介绍如何在实时计算中配置EMQ实时采集任务。
实时计算支持EMQ数据库的实时采集,当EMQ发生insert、update等操作时,实时采集组件可根据EMQ的LogMiner信息立即获取其操作,并实时将变更信息同步至目标数据源。

实时采集-参数配置

image.png
配置 说明

数据源

选择对应数据类型的已有数据源

Topic

选择数据源下指定Schema

解码器类型

EMQ实时采集可选择plain、json两种编码解码器类型;

清除Session

是:MQTT服务器不保存于客户端会话的的主题与确认位置
否:MQTT服务器保存于客户端会话的的主题与确认位置

服务质量qos

可选择三种不同的qos策略:

操作步骤

具体操作可参考快速开始中的 实时采集