文档首页 > > API参考> 快速入门

快速入门

分享
更新时间: 2019/08/23 GMT+08:00

场景描述

您可以根据业务需要购买相应计算能力和存储空间的Kafka实例,或者创建普通队列。

API调用方法请参考如何调用API

前提条件

创建队列

如下示例是创建有序队列的请求消息:
{
  "name" : "queue-001",
  "queue_mode" : "FIFO",
  "redrive_policy" : "enable",
  "max_consume_count" : 3
}
  • name:表示队列的名称,必须唯一,由您自行定义。
  • queue_mode:表示队列类型。取值范围:
    • NORMAL:普通队列,更高的并发性能,不保证先入先出(FIFO)的严格顺序。
    • FIFO:有序队列,保证消息先入先出(FIFO)的严格顺序。
    • KAFKA_HA:高可靠模式的kafka队列。消息多副本同步落盘,保证消息的可靠性。
    • KAFKA_HT:高吞吐模式的kafka队列。消息副本异步落盘,具有较高的性能。
  • redrive_policy:表示是否开启死信消息。取值范围:
    • enable:开启
    • disable:不开启
  • max_consume_count:表示最大确认消费失败的次数,当达到最大确认失败次数后,DMS会将该条消息转存到死信队列中。

参数更多描述,请参考创建队列

创建Kafka实例

如下示例是创建Kafka实例的请求消息:

{
	"name": "kafka-demo",
	"engine": "kafka",
	"engine_version": "1.1.0",
	"storage_space": 600,
	"kafka_manager_user": "******",
	"kafka_manager_password": "******",
	"vpc_id": "1a28dcc5-c90d-421c-82bb-783f30f5b40a",
	"security_group_id": "0cc8fdb7-872a-49da-a062-88ccc39463b5",
	"subnet_id": "ebba7994-260d-42ab-bce1-39a08b365dc8",
	"available_zones": ["ae04cf9d61544df3806a3feeb401b204"],
	"product_id": "00300-30308-0--0",
	"specification": "100MB",
	"storage_spec_code": "dms.physical.storage.ultra",
	"partition_num": "300"
}
  • name:实例名称。由您自行定义。
  • engine:消息引擎,设置kafka。
  • engine_version:消息引擎的版本。当前支持1.1.0。
  • storage_space:消息存储空间,单位GB。具体取值范围,请参考表2
  • kafka_manager_user:登录Kafka Manager的用户名,由您自行定义。
  • kafka_manager_password:登录Kafka Manager的用户名密码,由您自行定义。
  • vpc_id:Kafka实例所在的VPC(虚拟私有云)的ID。您可以在虚拟私有云控制台中查询,也可以通过查询VPC列表API查询。
  • security_group_id:安全组ID。您可以在虚拟私有云控制台中查询,也可以通过查询安全组列表API查询。。
  • subnet_id:VPC内子网的网络ID。您可以在虚拟私有云控制台中查询,也可以通过查询子网列表API查询。。
  • available_zones:创建节点到指定的AZ ID,该参数不能为空数组或者数组的值为空,详情请参考查询可用区信息查询得到。
  • product_id:产品标识。详情请参考查询产品规格列表
  • specification:Kafka实例的基准带宽。具体取值范围,请参考表2
  • storage_spec_code:存储IO规格。具体取值范围,请参考表2
  • partition_num:Kafka实例的最大分区数量。具体取值范围,请参考表2

分享:

    相关文档

    相关产品

文档是否有解决您的问题?

提交成功!

非常感谢您的反馈,我们会继续努力做到更好!

反馈提交失败,请稍后再试!

*必选

请至少选择或填写一项反馈信息

字符长度不能超过200

提交反馈 取消

如您有其它疑问,您也可以通过华为云社区问答频道来与我们联系探讨

跳转到云社区