伙伴订阅推送数据
针对设施云推送的数据,伙伴应用通过监听对应topic来订阅推送数据。
订阅步骤
- 订阅前先获取到KAFKA的服务端IP地址、用户名、密码以及需要订阅的Topic。具体监听代码指导可以参考华为云KAFKA的产品资料。链接如下:
https://support.huaweicloud.com/devg-kafka/kafka-spring.html
- 对应资料中涉及的client.jks证书文件请联系管理员获取。
- 监听到的资源消息格式和各个字段的说明可以查看智能设施云平台 API文档的“流转数据通知结构体定义”章节,如下图所示:
图1 推送格式
订阅推送数据的代码耗时不能太长,否则会导致消费组消息积压,如果监听到消息后需要复杂处理逻辑,建议采用异步方式处理。