检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
}/message-offset 响应示例 状态码： 200 查询成功 { "group_message_offsets" : [ ], "total" : 0 } 状态码 状态码 描述 200 查询成功 错误码 请参见错误码。 父主题： 消费组管理
c}/partitions/{partition}/beginning-message 响应示例 状态码： 200 查询分区最早消息的位置成功。 { "topic" : "mytest", "partition" : 0, "offset" : 9, "timestamp"
"execute_at" : 1695796358970 } 响应示例 状态码： 200 升级成功。 93b94287-728d-4bb1-a158-cb66cb0854e7 状态码 状态码 描述 200 升级成功。 400 升级失败。 错误码 请参见错误码。 父主题： 生命周期管理
a ## spring.kafka.properties.ssl.endpoint.identification.algorithm为证书域名校验开关，为空则表示关闭，这里需要保持关闭状态，必须设置为空。 spring.kafka.properties.ssl.endpoint.identification
Manager中仍可以看到此消费组，是因为Kafka Manager存在缓存。 通过以下任意一种方法解决此问题： 重启Kafka Manager。 Kafka Manager只显示14天内有消费记录的消费组，如果您不想重启Kafka Manager，可以等待14天后Kafka Manager自动清除此消费组。 父主题：
/{topic}/partitions/{partition}/end-message 响应示例 状态码： 200 查询分区最新消息的位置成功。 { "topic" : "mytest", "partition" : 0, "offset" : 9, "timestamp"
n}/message?message_offset={message_offset} 响应示例 状态码： 200 查询分区指定偏移量的消息成功。 { "message" : [ { "topic" : "mytest", "partition" : 0,
子网开启IPv6后，Kafka实例支持IPv6功能。 IPv6 子网开启IPv6后，页面才显示此参数。开启IPv6后，客户端可以使用IPv6地址连接实例。 开启IPv6的实例不支持动态开启和关闭SASL_SSL功能。 实例创建成功后，不支持修改IPv6开关。 此功能仅在“华东二”区域上线。 安全组 选择已经创建好的安全组。
导出Kafka消费组列表 消费组创建成功后，可导出Kafka实例中消费组的列表信息 导出Kafka消费组列表 登录管理控制台。 在管理控制台左上角单击，选择Kafka实例所在的区域。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务Kafka版”，进入分布式消息服务Kafka专享版页面。
"8959ab1c-7n1a-yyb1-a05t-93dfc361b32d" } 状态码 操作成功的状态码如表5所示，其他响应见状态码。 表5 状态码 状态码 描述 200 创建实例成功。 父主题： 实例管理类接口
nces/{instance_id}/delete-connector 响应示例 状态码： 200 提交关闭Smart Connect任务成功。 { "job_id" : "d366178c-29ea-4d5c-a344-fa2ece4a1836" } SDK代码示例 SDK代码示例如下。
s/{instance_id}/management/coordinators 响应示例 状态码： 200 查询Kafka实例的协调器信息成功。 { "coordinators" : [ { "group_id" : "XXXX", "id" : 2,
ances/{instance_id}/topics/{topic_name}/accesspolicy 响应示例 状态码： 200 查询成功。 { "name" : "topic-test", "policies" : [ { "owner" : false,
"value" : 10485760 } ], "topic_desc" : "" } 响应示例 状态码： 200 创建成功，返回topic名称 { "name" : "test01" } SDK代码示例 SDK代码示例如下。 Java Python Go 更多
topics/{topic}/partitions?start=1&limit=10 响应示例 状态码： 200 查询topic的分区列表成功 { "total" : 3, "partitions" : [ { "partition" : 0, "start_offset"
instances/{instance_id}/restart-kafka-manager 响应示例 状态码： 200 重启Manager成功。 { "result" : "success", "instance_id" : "605cd78c-92dc-4335-8bae-43677f31fd6c"
instance_id}/message-diagnosis/{report_id} 响应示例 状态码： 200 查询消息积压诊断报告详情成功 { "abnormal_item_num" : 2, "failed_item_num" : 2, "normal_item_num"
password为服务器证书密码，不可更改，需要保持为dms@kafka。 ssl.endpoint.identification.algorithm为证书域名校验开关，为空则表示关闭。这里需要保持关闭状态，必须设置为空。 username和password为首次开启密文接入时填入的用户名和密码，或者创建用户时设置的用户名和密码。
stances/{instance_id}/management/cluster 响应示例 状态码： 200 查询Kafka集群元数据信息成功。 { "cluster" : { "controller" : "2", "brokers" : [ {
es/{instance_id}/management/groups/{group} 响应示例 状态码： 200 查询实例集群的消费组信息成功。 { "group" : { "members" : [ { "host" : "/172.31.1.102",
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
