检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
consumer分配到的分区信息。 member_id String 消费组consumer的ID。 client_id String 客户端ID。 表5 assignment 参数 参数类型 描述 topic String topic名称。 partitions Array of
=file:D:\\temp\\client.jks ## spring.kafka.ssl.trust-store-password为服务器证书密码，无需修改，配置此密码是为了访问Java生成的jks文件。 spring.kafka.ssl.trust-store-password=dms@kafka
是否为contoller节点。 version String 服务端版本。 register_time Long broker注册时间，为unix时间戳格式。 is_health Boolean Kafka实例节点的连通性是否正常。 请求示例 GET https://{endpo
管理消息 查看Kafka消息 修改Kafka消息老化时间 删除Kafka消息 诊断Kafka消息积压
可为空。若为定时执行，is_schedule为true，execute_at字段非空。 execute_at 否 Long 定时时间，格式为Unix时间戳，单位为毫秒 响应参数 状态码： 200 表3 响应Body参数 参数 参数类型 描述 - String 提交升级任务id 状态码：
消息管理 查询消息 查询分区指定偏移量的消息 查询分区指定时间段的消息 查询分区最早消息的位置 查询分区最新消息的位置 Kafka删除消息 父主题： API V2（推荐）
2020-07-07 本次变更如下： 新增API V2（推荐）章节的V2接口。 2019-12-10 新增以下接口： 查询分区指定偏移量的消息 查询分区指定时间段的消息 查询分区最新消息的位置 查询分区最早消息的位置 查询Kafka集群元数据信息 查询消费组信息 重置消费组消费进度到指定位置 查询实例在CES的监控层级关系
NULL 默认值：换行符“\n”。 deliver_time_interval Integer 根据用户配置的时间，周期性的将数据导入OBS，若某个时间段内无数据，则此时间段不会生成打包文件。 取值范围：30～900，缺省值：300，单位：秒。 说明： 使用OBS通道转储流式数据时该参数为必选配置。
资源售罄的可用区列表。 available_zones Array of strings 有可用资源的可用区列表。 ecs_flavor_id String 该产品规格对应的虚拟机规格。 arch_type String 实例规格架构类型。当前仅支持X86。 表6 io 参数 参数类型 描述
Kafka服务和ZK是部署在相同的虚拟机中，还是分开部署？ Kafka服务和ZK部署在相同的虚拟机中。 父主题： 实例问题
String Kafka实例的基准带宽。 available_zones Array 实例资源未售罄的可用区。 ecs_flavor_id String 该产品规格对应的虚拟机规格。 arch_type String 实例规格架构类型。当前仅支持X86。 表6 io参数说明 参数 类型
partition Integer 分区编号。 message_offset Long 最新消息位置。 timestamp Long 最新消息时间戳。 响应示例 { "topic": "mytest", "partition": 0, "message_offset":
partition Integer 分区编号。 message_offset Long 最早消息位置。 timestamp Long 最早消息时间戳。 响应示例 { "topic": "mytest", "partition": 0, "message_offset
否 Integer 查询的任务个数。 begin_time 否 String 查询任务的最小时间，格式为YYYYMMDDHHmmss。 end_time 否 String 查询任务的最大时间，格式为YYYYMMDDHHmmss。 请求参数 无 响应参数 状态码： 200 表3 响应Body参数
分区编号。 message_offset Long 消息位置。 size Integer 消息大小，单位字节。 timestamp Long 消息时间戳。 响应示例 { "message": { "topic": "mytest",
产品ID可以从查询产品规格列表获取。 maintain_begin 否 String 维护时间窗开始时间，格式为HH:mm。 maintain_end 否 String 维护时间窗结束时间，格式为HH:mm。 enable_publicip 否 Boolean 是否开启公网访问功能。默认不开启公网。
total Integer 所有的消费组总数。 表4 GroupInfoSimple 参数 参数类型 描述 createdAt Long 创建时间。 group_id String 消费组ID。 state String 消费组状态。包含以下状态： Dead：消费组内没有任何成员，且没有任何元数据。
0尝试一次，直至Kafka实例到期或者续费成功。 开通自动续费后，还可以手动续费该Kafka实例。手动续费后，自动续费仍然有效，在新的到期时间前的第7天开始扣款。 自动续费的到期前7日自动扣款属于系统默认配置，您也可以根据需要修改此扣款日，如到期前6日、到期前5日等等。 更多关于
partition Integer 分区编号。 offset Integer 最新消息位置。 timestamp Long 生产消息的时间。 格式为Unix时间戳。单位为毫秒。 请求示例 GET https://{endpoint}/v2/{project_id}/instances/{
partition Integer 分区编号。 offset Integer 最新消息位置。 timestamp Long 生产消息的时间。 格式为Unix时间戳。单位为毫秒。 请求示例 GET https://{endpoint}/v2/{project_id}/instances/{
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
