检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
使用内网通过同一个VPC访问Kafka实例的连接地址（内网密文连接地址） 如果是公网访问，Kafka连接地址如下图所示。 图3 公网访问Kafka实例的连接地址（公网连接地址） 图4 公网访问Kafka实例的连接地址（公网密文连接地址） 已获取开启的SASL认证机制。 在Kafka实例详情页的“连接信息”区
获取途径 内网连接地址 在Kafka实例详情页的“连接信息”区域，获取“内网连接地址”。 开启的SASL认证机制 在Kafka实例详情页的“连接信息”区域，获取“开启的SASL认证机制”。 启用的安全协议 在Kafka实例详情页的“连接信息”区域，获取“启用的安全协议”。 证书
host String 消费组consumer地址。 assignment Array of object assignment consumer分配到的分区信息。参数请参见表5。 member_id String 消费组consumer的ID。 client_id String 客户端ID。
_SSL的Kafka实例，与连接未开启SASL_SSL的Kafka实例的端口号不同，且开启SASL_SSL的Kafka实例需要配置证书信息。 支持区域： 全部 连接未开启SASL的Kafka实例 连接已开启SASL的Kafka实例 跨VPC访问Kafka实例 使用DNAT访问Kafka实例
查询指定消费组 功能介绍 查询指定消费组。 调用方法 请参见如何调用API。 URI GET /v2/{engine}/{project_id}/instances/{instance_id}/groups/{group} 表1 路径参数 参数 是否必选 参数类型 描述 engine
在顶部区域，查看变更进度和预计剩余时间。在“任务执行步骤”中，查看执行步骤的名称和开始执行时间，以及结束时间。 查看变更是否成功。 变更规格任务的状态为“成功”时，表示变更成功。在实例列表页面的“规格”中查看扩容后的代理数量。 变更规格任务的状态为“失败”时，表示变更失败。把鼠标
实例连接地址与端口 实例创建后，从Kafka实例控制台的基本信息页面中获取。 如果Kafka实例为集群部署，至少有3个连接地址，在客户端配置时，建议配置所有的连接地址，提高可靠性。 如果开启公网访问，还可以使用基本信息页面下方的公网连接地址访问Kafka实例。 图1 查看Kafka实例Broker连接地址与端口
偏移量，表示从此偏移量开始查询， offset大于等于0。 limit 否 Integer 当次查询返回的最大消费组id个数，默认值为10，取值范围为1~50。 group 否 String 消费组名过滤查询，过滤方式为字段包含过滤。 topic 否 String 若指定topic，则只查询该topic的消费组。
spring-kafka的使用 本文介绍如何使用spring-kafka连接华为云Kafka实例进行消息的生产和消费。相关代码您可以从kafka-springboot-demo中获取。 下文所有Kafka的配置信息，如实例连接地址、Topic名称、用户信息等，请参考收集连接信息获取。
运行状态。 last_transfer_offset String 已转储的消息偏移量。 log_end_offset String 消息偏移量。 lag String 积压的消息数。 请求示例 查询指定的转储任务详情。 GET https://{endpoint}/v2/{pr
Println(err) } } 更多编程语言的SDK代码示例，请参见API Explorer的代码示例页签，可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 查询实例的扩容规格列表成功。 错误码 请参见错误码。 父主题： 规格变更管理
Kafka实例的ZK地址是什么？能否直接连接？ 为什么Console页面上，消息查询查不到消息？ 为什么实例可用区不能选择2个？ 更多 实例问题 Kafka实例的ZK地址是什么 Kafka实例的SASL_SSL开关如何修改？ Kafka实例是否支持修改访问端口？ Kafka实例的SSL证书有效期多长？
单击“确认”，完成证书的替换。 在“后台任务管理”页面，替换SSL证书任务的“状态”为“成功”时，表示替换证书成功。 证书替换成功后，在实例详情页单击“下载”，下载的证书为分布式消息服务Kafka版提供的证书，并非您自己制作的证书。 步骤三：修改客户端配置文件 替换证书后，需要在客户端的“consumer
如需停止消费使用Ctrl+C命令退出。 相关信息 了解Kafka实例的相关概念，请参考Kafka基本概念。 了解Kafka实例的价格，请参考分布式消息服务Kafka版价格详情。 在控制台查看消息，请参考查看Kafka消息。 查看消费进度，请参考查看Kafka消费进度。 查看Kafka实例的监控指标，请参考查看Kafka监控数据。
fmt.Println(err) } } 更多编程语言的SDK代码示例，请参见API Explorer的代码示例页签，可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 查询实例集群的所有消费组成功。 错误码 请参见错误码。 父主题： 消费组管理
修改转储任务的配额 功能介绍 修改转储任务的配额。 2022年9月前创建的实例支持调用此接口新增转储任务配额，2022年9月及以后创建的实例，转储任务配额默认为最大值，由于转储任务配额不支持减少，调用此接口修改转储任务配额会报错。 调用方法 请参见如何调用API。 URI PUT
partition Integer 否 分区编号，默认值为-1，若传入值为-1，则查询所有分区。 start_time Long 否 查询起始时间，为unix时间戳格式，默认值为0。 end_time Long 否 查询结束时间，为unix时间戳格式，默认值为系统当前时间。 limit Integer
Kafka实例的SSL证书有效期多长？ Kafka实例开启SASL_SSL时，需进行单向认证，证书有效期足够长（超过15年），客户端不需要关注证书过期风险。 查看SSL证书有效期的方法如下： 解压从Kafka实例控制台下载的压缩包，获取压缩包中的“phy_ca.crt”。 双击“phy_ca
Manager如何修改Topic的分区Leader？ 在Kafka Manager中修改Topic的分区Leader的步骤如下： 登录Kafka Manager。 选择“Topic > List”，进入Topic列表页面。 单击待修改分区Leader的Topic名称（以topic-
查询指定消费组的消费成员 功能介绍 查询指定消费组的消费成员。 调用方法 请参见如何调用API。 URI GET /v2/{engine}/{project_id}/instances/{instance_id}/groups/{group}/members 表1 路径参数 参数
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
