通用说明 API调用遵循HTTP协议,各Region采用不同的域名,具体域名见 服务域名 。数据交换格式为JSON,所有request/response body内容均采用UTF-8编码。 实名认证 使用Kafka API的用户需要实名认证,没有通过实名认证的可以前往 百度开放云官网控制台 中的安全认证下的实名认证中进行认证。没有通过实名认证的用户请求将会得到一下错误提示码: 错误码 错误描述 H
附录 订单相关 Billing相关 状态 类型 描述 paymentTiming String 付费方式。预付费:Prepaid,后付费:Postpaid reservation Reservation 保留信息,支付方式为后支付时不需要设置,预支付时必须设置 Reservation 状态 类型 描述 reservationLength int 时长 reservationTimeUnit Str
通过MQTT连接及收发消息 IoT Core 支持通过 MQTT 协议( v3.1.1)使用。当前支持QoS0和1的消息。 获取 MQTT 连接信息 在设备详情页,连接信息栏目,找到「DeviceSecret」字段,点击右侧小眼睛图标,查看连接信息,包含IoTCoreId、DeviceKey 和 DeviceSecret 或证书。
接口说明 Topic相关接口 创建Topic 描述 本接口用于创建一个Kafka topic。 请求 请求结构 POST /v{version}/topic?clientToken={clientToken} HTTP/1.1 { "topicName": "topicName", "partitionCount": partitionC
删除权限 该接口用于删除集群中指定的权限信息。 使用该接口时集群需要开启权限管理。 集群处于服务中状态(ACTIVE)。 请求结构 DELETE / v { version } / clusters / { clusterId } / acls ? username = { username } & patternType = { patternType } & resourceT
创建主题 该接口用于在集群中创建主题(topic)。 集群处于服务中状态(ACTIVE)。 请求结构 POST / v { version } / clusters / { clusterId } / topics HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization : authorization string {
服务域名 Kafka API的服务域名为: Region Endpoint Protocol 北京 http://kafka-api.bj.baidubce.com/v1 HTTP and HTTPS 广州 http://kafka-api.gz.baidubce.com/v1 HTTP and HTTPS 苏州 http://kafka-api.su.baidubce.com/v1 HTTP a
取消任务 该接口用于取消集群中的任务。 目前支持的任务类型只有:REASSIGN_PARTITION(主题调整)。 目前只有当主题调整任务设置为自定义执行时间,并且任务没有开始执行才能够取消任务。 请求结构 PUT / v { version } / clusters / { clusterId } / jobs / { jobId } / cancel HTTP / 1.1 Host : kaf
恢复任务 该接口用于恢复集群中已经暂停的任务。 目前支持的任务类型只有:REASSIGN_PARTITION(主题调整)。 只有任务状态为SUSPENDED(暂停)时才能恢复任务。 请求结构 PUT / v { version } / clusters / { clusterId } / jobs / { jobId } / resume HTTP / 1.1 Host : kafka - api