检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
是否支持跨Region访问？ Kafka可以跨Region访问，但是跨Region目前只能通过公网访问或者拉专线的方式。 父主题： 连接问题
"subnet_id": "3cb6afa2-xxx-05a7f671d6a8", "available_zones": [ "effdcbcxxx6b42f56533" ], "product_id": "c6.2u4g.cluster", "storage_spec_code":
"id":"1d7b939b382c4c3bb3481a8ca10da768", "name":"az10.dc1", "code":"az10.dc1", "port":"8002", "resource_availability":
Redis实例地址。（仅源端类型为Redis时会显示） redis_type String Redis实例类型。（仅源端类型为Redis时会显示） dcs_instance_id String DCS实例ID。（仅源端类型为Redis时会显示） sync_mode String 同步类型，“RDB_ONLY”为全
连接Kafka网络要求 客户端可以通过公网连接Kafka实例，也可以通过内网连接Kafka实例。使用内网连接时，注意以下几点： 如果客户端和Kafka实例部署在同一个VPC内，网络默认互通。 如果客户端和Kafka实例部署在不同VPC中，由于VPC之间逻辑隔离，客户端和Kafka
Redis实例地址。（仅源端类型为Redis时会显示） redis_type String Redis实例类型。（仅源端类型为Redis时会显示） dcs_instance_id String DCS实例ID。（仅源端类型为Redis时会显示） sync_mode String 同步类型，“RDB_ONLY”为全
选择和配置安全组 Kafka实例支持使用内网通过同一个VPC访问、跨VPC访问、通过DNAT访问和公网访问，访问实例前，需要配置安全组。 使用内网通过同一个VPC访问实例 客户端和实例是否使用相同的安全组？ 是，如果保留了创建安全组后，系统默认添加的入方向“允许安全组内的弹性云服
= true archTypeCreateInstanceByEngineReq:= "X86" enterpriseProjectIdCreateInstanceByEngineReq:= "0" enableAutoTopicCreateInstanceByEngineReq:=
概述 Kafka实例完全兼容开源Kafka协议，可以直接使用kafka开源客户端连接。如果“kafka安全协议”设置为“SASL_SSL”，则在开源客户端基础上使用云服务提供的证书文件。 本指南主要介绍实例连接信息的收集，如获取实例连接地址、Topic名称等，然后提供Java、Python和Go等语言的连接示例。
时需要填写） redis_type 否 String Redis实例类型。（仅源端类型为Redis时需要填写） dcs_instance_id 否 String DCS实例ID。（仅源端类型为Redis时需要填写） redis_password 否 String Redis密码。（仅源端类型为Redis时需要填写）
CreateInstanceUserRequest{} request.InstanceId = "{instance_id}" userPasswdCreateInstanceUserReq:= "Cxxx3" userNameCreateInstanceUserReq:= "test"
创建Kafka Topic Topic，即消息主题，用于存储消息，供生产者生产消息以及消费者订阅消息。创建Kafka实例成功后，如果没有开启“Kafka自动创建Topic”，需要手动创建Topic。如果实例开启了“Kafka自动创建Topic”，则该操作为可选。 “Kafka自动
true } 响应示例 状态码： 200 删除用户/客户端流控配置成功。 { "job_id" : "ff8080828bdc0f64018bdcadfd8f00d7" } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 删除用户/客户端流控配置。
查看和重置Kafka消费进度 消费进度表示消费者的消费位置，本章节介绍如何查看和重置消费进度，重置消费进度即修改消费者的消费位置。 重置消费进度可能会导致重复消费，请谨慎操作。 操作视频 本视频演示重置Kafka消费进度的操作。 前提条件 Kafka实例不支持在线重置消费进度，请
修改Kafka实例配置参数 分布式消息服务Kafka版为实例、Topic、消费者提供了几个常用配置参数的默认值，您可以根据实际业务需求，在控制台自行修改参数值。其他在控制台未列出的配置参数，请参考Kafka配置进行修改。 Kafka实例的参数分为动态参数和静态参数： 动态参数：动
2097152 } 响应示例 状态码： 200 创建用户/客户端流控配置成功。 { "job_id" : "ff8080828bdc0f64018bdcadfd8f00d7" } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 创建用户/客户端流控配置。
huaweiequipmentrootca successfully imported. Entry for alias huaweicloudca successfully imported. Import command completed: 3 entries successfully
快速连接Kafka并生产消费消息 本章节将为您介绍分布式消息服务Kafka版入门的使用流程，以创建一个开启密文接入、安全协议为SASL_SSL的Kafka实例，客户端使用内网通过同一个VPC连接Kafka实例生产消费消息为例，帮助您快速上手Kafka。 图1 Kafka使用流程 准备工作
重启Manager成功。 { "result" : "success", "instance_id" : "605cd78c-92dc-4335-8bae-43677f31fd6c" } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 1 2
查询成功。 { "task_count" : "1", "tasks" : [ { "id" : "8abfa7b272adc5b40172b73130065ae7", "name" : "bindInstancePublicIp", "user_name"
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
