检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
3.0版本或者Kafka命令行工具2.7.2版本或者Kafka命令行工具3.4.0版本，确保Kafka实例版本与命令行工具版本相同。 已在服务器中安装Java Development Kit 1.8.111或以上版本，并配置JAVA_HOME与PATH环境变量，具体方法如下： 使用执行用户在用户家目录下修改“
查询项目标签 功能介绍 查询项目标签。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/kafka/tags 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID，获取方式请参见获取项目ID。 请求参数
查询单个转储任务 功能介绍 查询单个转储任务。 当前页面API为历史版本API，未来可能停止维护。请使用查询Smart Connector任务详情。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/connectors/{connector_i
客户端网络环境说明 客户端可以通过以下方式访问Kafka实例： 如果客户端是云上ECS，与Kafka实例处于同region同VPC，则可以直接访问Kafka实例提供的内网连接地址。 如果客户端是云上ECS，与Kafka实例处于相同region但不同VPC，通过以下任意一种方式访问。
查询实例标签 功能介绍 查询实例标签。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/kafka/{instance_id}/tags 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID，获取方式请参见获取项目ID。
ID。其中Array首位为leader副本，所有分区需要有同样数量的副本，副本数不能大于总broker的数量。 响应参数 无 请求示例 修改Topic分区的副本分布位置，分区1的副本分布在broker 1和broker 2，Leader副本在broker 1。 POST https://{endpoint
云审计服务（Cloud Trace Service，简称CTS），是华为云安全解决方案中专业的日志审计服务，提供对各种云资源操作记录的收集、存储和查询功能，可用于支撑安全分析、合规审计、资源跟踪和问题定位等常见应用场景。 用户开通云审计服务并创建和配置追踪器后，CTS可记录DMS for
Kafka实例查询Topic 功能介绍 该接口用于查询指定Kafka实例的Topic详情。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/instances/{instance_id}/topics 表1 路径参数 参数 是否必选 参数类型 描述
Kafka实例查询Topic 当前页面API为历史版本API，未来可能停止维护。请使用Kafka实例查询Topic。 功能介绍 该接口用于查询指定Kafka实例的Topic详情。 URI GET /v1.0/{project_id}/instances/{instance_id}/topics
查询Kafka集群元数据信息 功能介绍 查询Kafka集群元数据信息。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/instances/{instance_id}/management/cluster 表1 路径参数 参数 是否必选 参数类型
客户端连接Kafka实例前，需要在Kafka实例所属安全组中配置如下安全组规则，否则会连接失败。 创建安全组后，系统默认添加入方向“允许安全组内的弹性云服务器彼此通信”规则和出方向“放通全部流量”规则，此时使用内网通过同一个VPC访问Kafka实例，无需添加表2的规则。 表2 安全组规则 方向
查询诊断报告详情 功能介绍 查询诊断报告详情 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/kafka/instances/{instance_id}/message-diagnosis/{report_id} 表1 路径参数 参数 是否必选
查询用户列表 功能介绍 查询用户列表。 Kafka实例开启SASL功能时，才支持多用户管理的功能。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/instances/{instance_id}/users 表1 路径参数 参数 是否必选 参数类型
偏移量，表示从此偏移量开始查询， offset大于等于0。 limit 否 Integer 当次查询返回的最大消费组id个数，默认值为10，取值范围为1~50。 group 否 String 消费组名过滤查询，过滤方式为字段包含过滤。 topic 否 String 若指定topic，则只查询该topic的消费组。
offset 否 String 偏移量，表示从此偏移量开始查询， offset大于等于0。 limit 否 String 当次查询返回的最大消费组ID个数，默认值为10，取值范围为1~50。 group 否 String 消费组名过滤查询，过滤方式为字段包含过滤。 请求参数 无 响应参数
创建Topic、查询Topic、修改Topic等接口。 用户管理，包括用户管理接口对应的授权项，如创建用户、查询用户列表、设置用户权限等接口。 消息查询，包括消息查询接口对应的授权项，如查询消息接口。 后台任务管理，包括实例的后台任务管理接口对应的授权项，如查询实例的后台任务列表、查询后台任务管理中的指定记录等接口。
opic的数据量和CPU使用率可以通过监控页面的“队列数据容量”和“CPU使用率”查看，具体步骤请参考查看Kafka监控数据。 带宽限制是指设定Topic进行副本同步的带宽上限，确保不会对该实例上的其他Topic造成流量冲击。但需要注意，带宽限制不会区分是正常的生产消息造成的副本
户的安全责任在于对使用的IaaS、PaaS和SaaS类云服务内部的安全以及对租户定制配置进行安全有效的管理，包括但不限于虚拟网络、虚拟主机和访客虚拟机的操作系统，虚拟防火墙、API网关和高级安全服务，各项云服务，租户数据，以及身份账号和密钥管理等方面的安全配置。 《华为云安全白皮
为什么Console页面上，消息查询查不到消息？ 可能原因1：消息已被老化。 解决方法：修改老化时间。 可能原因2：消息的createTime时间戳不对。 Console页面是根据时间查询的，所以查不到。时间戳是由客户端生成，不同客户端有不同的处理策略，有的客户端默认值会是0或者-1，则查询不到消息。
=file:D:\\temp\\client.jks ## spring.kafka.ssl.trust-store-password为服务器证书密码，无需修改，配置此密码是为了访问Java生成的jks文件。 spring.kafka.ssl.trust-store-password=dms@kafka
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
