查询主题订阅详情 该接口用于查询集群中指定消费组对指定主题(topic)各个分区的订阅详细信息。 请求结构 GET / v { version } / clusters / { clusterId } / topics / { topicName } / consumer - groups / { groupName } / subscribe - details HTTP / 1.1 Host
查询主题分区详情 该接口用于查询指定集群的主题的指定分区信息。 请求结构 GET / v { version } / clusters / { clusterId } / topics / { topicName } / partitions / { partitionId } / statuses HTTP / 1.1 Host : kafka - api . bj . baidubce . c
查询主题分区列表 该接口用于查询指定集群的主题的所有分区信息。 请求结构 GET / v { version } / clusters / { clusterId } / topics / { topicName } / partitions / statuses HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization :
查询集群配置详情 该接口用于查询指定集群配置的详情信息。 请求结构 GET / v { version } / configs / { configId } HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization : authorization string 请求头域 除公共头域外,无其他特殊头域。 请求参数 参数名称 类
启动消费者 go consumer.go # 启动生产者 go producer.go 步骤五:查看集群监控 查看消息是否发送成功或消费成功有两种方式: 查看程序输出日志。 在专享版消息服务 for Kafka控制台查看集群监控,获取集群生产、消息情况。 推荐使用第二种方式,下面介绍如何查看集群监控。
启动消费者 php consumer.php # 启动生产者 php producer.php 步骤五:查看集群监控 查看消息是否发送成功或消费成功有两种方式: 查看程序输出日志。 在专享版消息服务 for Kafka控制台查看集群监控,获取集群生产、消息情况。 推荐使用第二种方式,下面介绍如何查看集群监控。
VPC网络SASL_PLAINTEXT方式生产和消费消息 在同 VPC 网络下访问,使用 SASL_PLAINTEXT 协议接入,接入点可以在 集群详情 页面查看。 环境准备 安装1.8或以上版本 JDK 安装2.5或以上版本 Maven 集群准备 1. 购买专享版消息服务for Kafka集群 开通消息服务 for Kafka服务后,在控制台页面点击『创建集群』,即可进行购买。 2.
启动消费者 python KafkaConsumerDemo.py # 启动生产者 python KafkaProducerDemo.py 步骤四:查看集群监控 查看消息是否发送成功或消费成功有两种方式: 查看程序输出日志。 在专享版消息服务 for Kafka控制台查看集群监控,获取集群生产、消息情况。 推荐使用第二种方式,下面介绍如何查看集群监控。
对于定时任务消息,如果未到下发时间,消息将撤销不下发; 对于已经发送的消息,已经收到消息的设备将正常展示,尚未下发的设备则不下发。
启动消费者 go consumer.go # 启动生产者 go producer.go 步骤四:查看集群监控 查看消息是否发送成功或消费成功有两种方式: 查看程序输出日志。 在专享版消息服务 for Kafka控制台查看集群监控,获取集群生产、消息情况。 推荐使用第二种方式,下面介绍如何查看集群监控。