华为云物联网平台数据转发至Kafka储存
场景说明
华为云设备接入IoTDA服务对于设备上报的数据，可以选择让平台将设备上报数据推送给应用服务器，由应用服务器进行保存；还可以选择让平台将设备上报数据转发给分布式消息服务（Kafka），由Kafka进行存储。
本示例为将所有设备上报的数据转发至Kafka存储。
购买Kafka实例
配置 设备接入服务
在设备接入服务中创建产品模型、注册设备并设置数据转发规则，实现当设备上报数据时将数据转发至Kafka。
- 访问设备接入服务，单击“立即使用”进入设备接入控制台。
- 在左侧导航栏选择“规则>数据转发”，单击右上角的“创建规则”。
- 参考下表参数说明，填写规则内容。以下参数取值仅为示例，您可参考用户指南创建自己的规则，填写完成后单击“创建规则”。
参数名
参数说明
规则名称
自定义，如iotda-kafka。
规则描述
自定义，如数据转发至Kafka存储。
数据来源
选择“设备属性”。
触发事件
自动匹配“设备属性上报”。
资源空间
选择“所有资源空间”。
图2 创建数据转发规则
- 单击“设置转发目标”页签，单击“添加”，设置转发目标。
参数名
参数说明
转发目标
选择“分布式消息服务(kafka)”
区域
选择Kafka服务的所在区域。若未授权访问此区域的服务，请根据界面提示，配置 云服务 访问授权。
对接地址
参考连接已开启SASL的Kafka专享版实例获取对接地址。设备接入基础版和标准版实例只支持公网接入专享版Kafka，企业版实例支持私网接入专享版Kafka。
主题
自定义主题，参考创建Topic。
数据加密 传输
若开启数据加密传输，SASL用户名和密码，填写您在购买Kafka实例中输入的SASL用户名和密码。
SASL用户名
填写您在购买Kafka实例中输入的SASL用户名。
密码
填写您在购买Kafka实例中输入的密码。
图3 创建数据转发目标
- 单击“启动规则”，激活配置好的数据转发规则。
图4 激活规则
验证操作
- 您可以使用配置设备接入服务时注册的真实设备接入平台，上报任意数据。
- 您也可以使用模拟器模拟设备上报数据，操作方法请参考在线开发MQTT协议的智慧路灯。
期望结果：
登录Kafka管理控制台，单击Kafka实例名进入实例管理页面后，在“消息查询”页面可以查看到设备上报的数据。
图5 Kafka服务查询数据上报信息
您也可以使用Kafka的API（查询消息）进行文件读取。
