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

配置 | 说明 |
---|---|
数据源 |
选择对应数据类型的已有数据源 |
Topic |
选择数据源下指定Schema |
解码器类型 |
EMQ实时采集可选择plain、json两种编码解码器类型; |
清除Session |
是:MQTT服务器不保存于客户端会话的的主题与确认位置 |
服务质量qos |
可选择三种不同的qos策略: |
操作步骤
具体操作可参考快速开始中的 实时采集。