检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
Flink 1.15消费进度提交失败 问题现象 Flink 1.15版本消费Kafka时， 消费进度提交失败，持续报错：COORDINATOR_NOT_AVAILABLE。 根因描述 Flink 1.15版本使用的Kafka客户端存在bug，当某次消费进度提交失败后， 客户端将c
查询消息积压诊断报告列表 功能介绍 查询消息积压诊断报告列表 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/kafka/instances/{instance_id}/message-diagnosis-tasks 表1 路径参数 参数 是否必选
查询分区指定偏移量的消息 当前页面API为历史版本API，未来可能停止维护。 URI GET /v1.0/{project_id}/instance/{instance_id}/manage/topic/{topic_name}/partition/{partition}/off
查询实例在CES的监控层级关系 功能介绍 查询实例在CES的监控层级关系。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/instances/{instance_id}/ces-hierarchy 表1 路径参数 参数 是否必选 参数类型 描述
查询后台任务管理中的指定记录 功能介绍 查询后台任务管理中的指定记录。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/instances/{instance_id}/tasks/{task_id} 表1 路径参数 参数 是否必选 参数类型 描述
查询Smart Connect任务列表 功能介绍 查询Smart Connect任务列表。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/instances/{instance_id}/connector/tasks 表1 路径参数 参数 是否必选
查询分区最新消息的位置 当前页面API为历史版本API，未来可能停止维护。请使用查询分区最新消息的位置。 URI GET /v1.0/{project_id}/instances/{instance_id}/manage/topics/{topic}/partitions/{pa
可使用分布式消息服务Kafka版，做到无缝迁移。 Kafka实例兼容开源社区Kafka 1.1.0、2.7、3.x版本。在客户端使用上，推荐使用和服务端版本一致的版本。 安全保证 独有的安全加固体系，提供业务操作云端审计，消息传输加密等有效安全措施。 在网络通信方面，除了提供SASL（Simple
查询产品规格列表 当前页面API为历史版本API，未来可能停止维护。请使用查询产品规格列表。 功能介绍 在创建kafka实例时，需要配置订购的产品ID（即product_id），可通过该接口查询产品规格。 例如，要订购按需计费、基准带宽为100MB的kafka实例，可从接口响应消
查询Topic的当前生产者列表 功能介绍 查询Topic的当前生产者列表 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/kafka/instances/{instance_id}/topics/{topic}/producers 表1 路径参数
start 否 Integer 开启查询的任务编号。 limit 否 Integer 查询的任务个数。 begin_time 否 String 查询任务的最小时间，格式为YYYYMMDDHHmmss。 end_time 否 String 查询任务的最大时间，格式为YYYYMMDDHHmmss。
Manager能否查询到消息的正文？ Kafka Manager WebUI的端口能否修改？ 在Kafka Manager上支持修改Topic的哪些属性？ Kafka Manager和云监控显示的信息不一致 Kafka Manager如何修改Topic的分区Leader？ 实例版本在控制台和Kafka
查询用户/客户端流控配置 功能介绍 该接口用于向Kafka实例查询流控的配置，若成功则返回流控配置的列表。 调用方法 请参见如何调用API。 URI GET /v2/kafka/{project_id}/instances/{instance_id}/kafka-user-client-quota
修改实例信息 功能介绍 修改实例信息。 调用方法 请参见如何调用API。 URI PUT /v2/{project_id}/instances/{instance_id} 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID，获取方式请参见获取项目ID。
取。 available_zones：创建节点到指定的AZ ID，该参数不能为空数组或者数组的值为空，请参考查询可用区信息获取。 product_id：产品标识。请参考查询产品规格列表获取。 storage_spec_code：存储IO规格。具体取值范围，请参考创建实例。
关闭Smart Connect（按需实例） 功能介绍 介绍按需实例如何关闭Smart Connect。 调用方法 请参见如何调用API。 URI POST /v2/{project_id}/kafka/instances/{instance_id}/delete-connector
集群实例 版本 支持2.7版本。 支持1.1.0、2.7和3.x版本。 可用区 支持单可用区。 支持1个或者3个及以上可用区。 代理数量 1个代理。 3个及以上代理。 接入方式 支持明文接入。 支持明文接入和密文接入。 变更实例规格 × √ 重置Kafka密码 × √ 查看磁盘使用量
查询实例在CES的监控层级关系 当前页面API为历史版本API，未来可能停止维护。请使用查询实例在CES的监控层级关系。 URI GET /v1.0/dms/{project_id}/instances/{instance_id}/ceshierarchy 参数说明见表1。 表1
管理实例 查看和修改Kafka实例基本信息 查看Kafka磁盘使用量 查看Kafka实例后台任务 查看Kafka生产消费示例代码 修改Kafka实例配置参数 配置Kafka实例标签 配置Kafka实例回收站策略 升级Kafka实例内核版本 导出Kafka实例列表 重启Kafka实例
删除指定消费组 功能介绍 删除指定消费组。 调用方法 请参见如何调用API。 URI DELETE /v2/{engine}/{project_id}/instances/{instance_id}/groups/{group} 表1 路径参数 参数 是否必选 参数类型 描述 engine
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
