检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
可以错峰进行消息处理。 另外,在商品秒杀、抢购等流量短时间内暴增场景中,为了防止后端应用被压垮,可在前后端系统间使用Kafka消息队列传递请求。 图3 消息队列应对秒杀大流量场景 日志同步 在大型业务系统设计中,为了快速定位问题,全链路追踪日志,以及故障及时预警监控,通常需要将各系统应用的日志集中分析处理。
描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 请求参数 无 响应参数 状态码: 200 表2 响应Body参数 参数 参数类型 描述 cluster cluster object 集群基本信息。
项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 group 是 String 消费组名称。 请求参数 无 响应参数 状态码: 200 表2 响应Body参数 参数 参数类型 描述 group group object 消费组信息。 表3
项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 topic 是 String Topic名称。 请求参数 无 响应参数 状态码: 200 表2 响应Body参数 参数 参数类型 描述 topic String topic名称。 partitions
查询任务的最小时间,格式为YYYYMMDDHHmmss。 end_time 否 String 查询任务的最大时间,格式为YYYYMMDDHHmmss。 请求参数 无 响应参数 状态码: 200 表3 响应Body参数 参数 参数类型 描述 task_count String 任务数量。 tasks
参数类型 描述 offset 否 Integer 偏移量,表示查询该偏移量后面的记录 limit 否 Integer 查询返回记录的数量限制 请求参数 无 响应参数 状态码: 200 表3 响应Body参数 参数 参数类型 描述 report_list Array of KafkaM
参数类型 描述 offset 否 Integer 偏移量,表示查询该偏移量后面的记录。 limit 否 Integer 查询返回记录的数量限制。 请求参数 无 响应参数 状态码: 200 表3 响应Body参数 参数 参数类型 描述 quotas Array of Quota objects
项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID report_id 是 String 消息积压诊断报告ID 请求参数 无 响应参数 状态码: 200 表2 响应Body参数 参数 参数类型 描述 abnormal_item_num Integer 诊断异常的诊断项总和
POST https://{endpoint}/v1/{project_id}/vpc-endpoint-services 请参考以下说明设置请求参数,其他参数根据实际情况设置。 port_id:输入6中获取的其中一个Port ID。 vpc_id:输入8中获取的VPC ID。 server_type:输入“VM”。
消费成功或失败的状态,并将消费状态提交到分布式消息服务Kafka版。 在消费过程中,如果出现异常,没有提交消费确认,该批消息会在后续的消费请求中再次被获取。 消息生产与消费的幂等传递 分布式消息服务Kafka版设计了一系列可靠性保障措施,确保消息不丢失。例如使用消息同步存储机制防
UPDATE_MEMBER: 消费者更新元数据。 PROTOCOL_CHANGE:协议变化。 HEARTBEAT_EXPIRED:消费者心跳超时。 SYNC_GROUP:同步分配计划。 END_REBALANCE:重平衡结束。 LEAVE_GROUP:消费者主动离开消费组。 group
(1K,1M,1G)。 top 否 String 占用磁盘大小,查询top N。 percentage 否 String 占用磁盘大小,查询大于占比的分区。 请求参数 无 响应参数 状态码: 200 表3 响应Body参数 参数 参数类型 描述 broker_list Array of DiskusageEntity
项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 group 是 String 消费组名称。 请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 topic 否 String topic名称。 partition 是 Integer
偏移量,表示从此偏移量开始查询, offset大于等于0。 limit 否 String 当次查询返回的最大实例个数,默认值为10,取值范围为1~50。 请求参数 无 响应参数 状态码: 200 表3 响应Body参数 参数 参数类型 描述 total Integer topic总数。 size
描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 请求参数 无 响应参数 状态码: 200 表2 响应Body参数 参数 参数类型 描述 kafka_configs Array of InstanceConfig
查询消息内容时,为必选参数。 若start_time、end_time参数不为空,该参数无效。 keyword 否 String 关键词。 取值范围为0~50。 请求参数 无 响应参数 状态码: 200 表3 响应Body参数 参数 参数类型 描述 messages Array of MessagesEntity
project_id 是 String 项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 specification 否 String 部署Smart Connect的规格,
project_id 是 String 项目ID。 instance_id 是 String 实例ID。 group 是 String 消费组名称。 请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 topic 否 String topic名称。 partition 是 Integer
描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 请求参数 无 响应参数 状态码: 200 表2 响应Body参数 参数 参数类型 描述 dimensions Array of dimensions
表2 Query参数 参数 是否必选 参数类型 描述 topic-info 否 String 是否包含topic信息。默认是false。 请求参数 无 响应参数 状态码: 200 表3 响应Body参数 参数 参数类型 描述 task_name String 转储任务名称。 destination_type