消息服务 for RabbitMQ

启动消费者 python KafkaConsumerDemo.py # 启动生产者 python KafkaProducerDemo.py 步骤四：查看集群监控 查看消息是否发送成功或消费成功有两种方式： 查看程序输出日志。 在专享版消息服务 for Kafka控制台查看集群监控，获取集群生产、消息情况。 推荐使用第二种方式，下面介绍如何查看集群监控。

查看更多>>

启动消费者 go consumer.go # 启动生产者 go producer.go 步骤四：查看集群监控 查看消息是否发送成功或消费成功有两种方式： 查看程序输出日志。 在专享版消息服务 for Kafka控制台查看集群监控，获取集群生产、消息情况。 推荐使用第二种方式，下面介绍如何查看集群监控。

查看更多>>

删除权限 该接口用于删除集群中指定的权限信息。 使用该接口时集群需要开启权限管理。 集群处于服务中状态（ACTIVE）。 请求结构 DELETE / v { version } / clusters / { clusterId } / acls ? username = { username } & patternType = { patternType } & resourceT

查看更多>>

启动任务 该接口用于启动集群中的任务。 目前支持的任务类型只有：REASSIGN_PARTITION（主题调整）。 请求结构 PUT / v { version } / clusters / { clusterId } / jobs / { jobId } / start HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorizati

查看更多>>

停止集群 该接口用于停止集群。 请求结构 PUT / v { version } / clusters / { clusterId } / stop HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization : authorization string 请求头域 除公共头域外，无其他特殊头域。 请求参数 参数名称 类型 是否

查看更多>>

删除主题 该接口用于删除集群中的主题（topic）。 集群处于服务中状态（ACTIVE）。 请求结构 DELETE / v { version } / clusters / { clusterId } / topics / { topicName } HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization : author

查看更多>>

产品优势 兼容开源 100%兼容开源社区版本，业务无需改动即可快速完成迁移上云，在节约成本的同时使您更加专注于业务开发。 运维无忧 配备完整的监控告警等运维服务，与百度智能云专业的云监控（BCM）服务打通，日常运维提供丰富的监控指标，出现故障自动发送告警，提供7×24小时的实时监控服务，为您的系统保驾护航。 规格灵活 可对专享实例节点、带宽与存储资源进行灵活配置组合，自定义集群下主题的分区数、副本

查看更多>>

接口说明 Topic相关接口 创建Topic 描述 本接口用于创建一个Kafka topic。 请求 请求结构 POST /v{version}/topic?clientToken={clientToken} HTTP/1.1 { "topicName": "topicName", "partitionCount": partitionC

查看更多>>