本文为您介绍不同语言SDK的消息订阅开发指导。在DataWorks开放平台开启消息订阅功能后,您除了需要完成订阅对象Topic在Comsumer的相关配置,还需要在Consumer上配置好消息队列Kafka版的接入信息,用于接收订阅的消息。

前提条件

已开启消息订阅功能并完成相关配置,详情请参见开启消息订阅

使用限制

  • DataWorks的开放消息仅支持使用消息队列Kafka版的SSL接入点PLAIN机制进行收发消息。
  • DataWorks的开放消息仅支持2.2.0版本的消息队列Kafka版,建议客户端和服务端版本保持一致。

开发指引

DataWorks使用的消息队列Kafka版可以支持不同语言SDK开发消息收发程序,支持的SDK语言包括:java、python、C++、Go、PHP、Ruby、Node.js和C#,不同SDK的消息开发指引请参考下表。

注意
  • 开发消息订阅时,Topic、Consumer Group、用户及SSL接入点等配置信息可以在DataWorks控制台开放消息页面获取。
  • 配置依赖时,如果需要配置Kafka版本信息,请配置为2.2.0。
  • 开发消息订阅时,无需配置发送消息,其他准备配置和订阅消息,请根据各SDK要求进行操作。
SDK类型 网络环境 协议 端口 参考文档 Demo
Java VPC SASL_SSL 9093 SSL接入点PLAIN机制收发消息 SASL_SSL/PLAIN
python 公网 SASL_SSL 9093 SSL接入点PLAIN机制收发消息 SASL_SSL/PLAIN
C++ 公网 SASL_SSL 9093 SSL接入点PLAIN机制收发消息 SASL_SSL/PLAIN
Go 公网 SASL_SSL 9093 SSL接入点PLAIN机制收发消息 SASL_PLAIN
PHP 公网 SASL_SSL 9093 SSL接入点PLAIN机制收发消息 SASL_SSL/PLAIN
Ruby 公网 SASL_SSL 9093 SSL接入点PLAIN机制收发消息 SASL_SSL/PLAIN
Node.js 公网 SASL_SSL 9093 SSL接入点PLAIN机制收发消息 SASL_PLAIN
C# 公网 SASL_SSL 9093 SSL接入点PLAIN机制收发消息

后续步骤

现在您已经完成了消息订阅配置和开发工作,消息队列Kafka版的consumer获取到消息后,会根据消息格式进行解析并将事件变更状态信息通知到您,帮助您快速响应消息变化状态,消息格式请参见附录:消息格式