启动消费者 php consumer.php # 启动生产者 php producer.php 步骤四:查看集群监控 查看消息是否发送成功或消费成功有两种方式: 查看程序输出日志。 在专享版消息服务 for Kafka控制台查看集群监控,获取集群生产、消息情况。 推荐使用第二种方式,下面介绍如何查看集群监控。
通过 MQTT 连接 IoT Core 支持通过 MQTT 协议进行连接及消息收发,可点击 查看 MQTT 使用方式 。 通过 HTTP/HTTPS 发布消息 IoT Core 支持通过 HTTP/HTTPS 协议进行消息发布,可点击 查看 HTTP 使用方式 。 通过 CoAP 发布消息 IoT Core 支持通过 CoAP 协议进行消息发布,可点击 查看 CoAP 使用方式 。
创建集群 该接口用于创建集群。 针对创建集群白名单中的用户。 请求结构 POST / v { version } / clusters HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization : authorization string 请求头域 除公共头域外,无其他特殊头域。 请求参数 参数名称 类型 是否必须 参数位置
通用说明 API调用遵循HTTP协议,各Region采用不同的域名,具体域名见 服务域名 。数据交换格式为JSON,所有request/response body内容均采用UTF-8编码。 实名认证 使用Kafka API的用户需要实名认证,没有通过实名认证的可以前往 百度开放云官网控制台 中的安全认证下的实名认证中进行认证。没有通过实名认证的用户请求将会得到一下错误提示码: 错误码 错误描述 H
附录 订单相关 Billing相关 状态 类型 描述 paymentTiming String 付费方式。预付费:Prepaid,后付费:Postpaid reservation Reservation 保留信息,支付方式为后支付时不需要设置,预支付时必须设置 Reservation 状态 类型 描述 reservationLength int 时长 reservationTimeUnit Str
certificateCN": , "createAt": , "revokeAt": , "certificate": , "privateKey": , "region": , "description": , "isPrivilege":} } 创建普通证书
通过MQTT连接及收发消息 IoT Core 支持通过 MQTT 协议( v3.1.1)使用。当前支持QoS0和1的消息。 获取 MQTT 连接信息 在设备详情页,连接信息栏目,找到「DeviceSecret」字段,点击右侧小眼睛图标,查看连接信息,包含IoTCoreId、DeviceKey 和 DeviceSecret 或证书。
变更主题 该接口用于变更集群中指定主题(topic)的配置信息。 集群处于服务中状态(ACTIVE)。 请求结构 PUT / v { version } / clusters / { clusterId } / topics / { topicName } HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization : aut
启动集群 该接口用于启动集群。 请求结构 PUT / v { version } / clusters / { clusterId } / start HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization : authorization string 请求头域 除公共头域外,无其他特殊头域。 请求参数 参数名称 类型 是
暂停任务 该接口用于暂停集群中已经启动的任务。 目前支持的任务类型只有:REASSIGN_PARTITION(主题调整)。 只有任务状态为RUNNING(执行中)的情况下才能够暂停任务。 请求结构 PUT / v { version } / clusters / { clusterId } / jobs / { jobId } / suspend HTTP / 1.1 Host : kafka -