pics 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 表2 Query参数 参数 是否必选 参数类型 描述 offset 否 String 偏移量,表示从此偏移量开始查询,
ages 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 表2 Query参数 参数 是否必选 参数类型 描述 topic 是 String Topic名称。
据发送失败后,客户端会重新发送。 注意,这些重试与客户端接收到发送错误时的重试没有什么不同。允许重试将潜在的改变数据的顺序,如果这两个消息记录都是发送到同一个partition,则第一个消息失败第二个发送成功,则第二条消息会比第一条消息出现要早。 针对网络闪断场景,生产者建议配置
转储任务ID。 表2 Query参数 参数 是否必选 参数类型 描述 topic-info 否 String 是否包含topic信息。默认是false。 请求参数 无 响应参数 状态码: 200 表3 响应Body参数 参数 参数类型 描述 task_name String 转储任务名称。
表3 响应Body参数 参数 参数类型 描述 [数组元素] Array of KafkaDiagnosisCheckEntity objects Kafka消息积压诊断预检查返回对象 表4 KafkaDiagnosisCheckEntity 参数 参数类型 描述 name String
转储地址。(仅目标端类型为OBS时会显示) obs_path String 转储目录。(仅目标端类型为OBS时会显示) partition_format String 时间目录格式。(仅目标端类型为OBS时会显示) record_delimiter String 记录分行符。(仅目标端类型为OBS时会显示)
String 消费组名称。 请求参数 无 响应参数 状态码: 200 表2 响应Body参数 参数 参数类型 描述 group group object 消费组信息。 表3 group 参数 参数类型 描述 group_id String 消费组名称。 state String 消费组状态。包含以下状态:
tash如何对接Kafka实例生产消费消息。 使用MirrorMaker跨集群同步数据 使用MirrorMaker可以实现将源集群中的数据镜像复制到目标集群中。本章节介绍两个Kafka实例如何使用MirrorMaker单向或双向同步数据。 消息堆积处理建议 本章节描述了消息堆积的原因,以及处理措施。
例费用账单和存储空间费用账单)到计费系统进行结算。 按需计费模式的资源按照固定周期上报使用量到计费系统进行结算。按需计费模式产品根据使用量类型的不同,分为按小时、按天、按月三种周期进行结算,具体扣费规则可以参考按需产品周期结算说明。Kafka实例的按需计费模式按小时进行结算。 按
内的弹性云服务器彼此通信”规则和出方向“放通全部流量”规则,则无需添加其他规则。否则,请添加表1所示规则。 表1 安全组规则 方向 协议 类型 端口 源地址 说明 入方向 TCP IPv4 9092 Kafka客户端所在的IP地址或地址组 使用内网通过同一个VPC访问Kafka实例(明文接入)。
stances/{instance_id}/message-diagnosis/{report_id} 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID
是 String 产品的类型。 advanced: 专享版 请求参数 无 响应参数 状态码: 200 表3 响应Body参数 参数 参数类型 描述 engine String 消息引擎类型:kafka。 versions Array of strings 消息引擎支持的版本。 products
String 该产品规格对应的虚拟机规格。 arch_type String 实例规格架构类型。当前仅支持X86。 表6 io参数说明 参数 类型 说明 io_type String IO类型。 storage_spec_code String IO规格。 available_zones
/v2/{engine}/{project_id}/instances/{instance_id}/groups/{group} 表1 路径参数 参数 是否必选 参数类型 描述 engine 是 String 引擎。 project_id 是 String 项目ID,获取方式请参见获取项目ID。 instance_id
tion 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID 表2 Query参数 参数 是否必选 参数类型 描述 action_id 是 String
sage 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 表2 Query参数 参数 是否必选 参数类型 描述 minSize 否 String 占用磁盘大小,默认值1G
e 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 topics 否 Array
e 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 group_ids 是 Array
Integer 偏移量,表示查询该偏移量后面的记录 limit 否 Integer 查询返回记录的数量限制 请求参数 无 响应参数 状态码: 200 表3 响应Body参数 参数 参数类型 描述 total Integer 总条数 partitions Array of partitions
Integer 分区编号。 表2 Query参数 参数 是否必选 参数类型 描述 message_offset 是 String 消息位置。 请求参数 无 响应参数 状态码: 200 表3 响应Body参数 参数 参数类型 描述 message Array of ShowPartitionMessageEntity
您即将访问非华为云网站,请注意账号财产安全