检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
使用前请参考收集连接信息收集Kafka所需的连接信息。 准备环境 执行以下命令，检查是否已安装Go。 go version 返回如下回显时，说明Go已经安装。 [root@ecs-test confluent-kafka-go]# go version go version go1.16.5 linux/amd64
rebalance group 1 表示消费组开始进行rebalance，消费组状态变更为REABLANCING。 Stabilized group 表示消费组rebalance完成，消费组状态变更为STABILIZED。 Member consumer-xxx in group 1
关于Kafka的帮助手册阅读指引 受限于篇幅，我们提供的Kafka帮助手册重点描述产品相关的内容，以及与开源社区版Kafka的差异部分，例如华为云Kafka的产品规格、控制台操作、客户端对接等。 如果您需要了解Kafka入门知识或消息生产、消费等方面的技术细节，请查阅Kafka官网资料。 介绍视频
icy 创建实例 √ × × × × × × × 修改实例 √ × × × × × × × 删除实例 √ × × × × × × × 变更实例规格 √ × × × × × × × 开启Smart Connect √ × × × × × × × 创建Smart Connect任务 √
engine String 消息引擎。 engine_version String 消息引擎版本。 specification String 实例规格。 storage_space Integer 消息存储空间，单位：GB。 partition_num String Kafka实例的总分区数。
Smart Connect任务创建成功后，不支持修改任务参数。 前提条件 已开启Smart Connect。 已创建Kafka实例，且实例状态为“运行中”。 配置Kafka间的数据复制 登录管理控制台。 在管理控制台左上角单击，选择区域。 请选择Kafka实例所在的区域。 在管理控制台左上角单击，选择“应用中间件
实例名称。 engine String 引擎。 engine_version String 版本。 specification String 实例规格。 storage_space Integer 消息存储空间，单位：GB。 partition_num String Kafka实例的最大topic数。
engine_version String 版本。 description String 实例描述。 specification String 实例规格。 storage_space Integer 消息存储空间，单位：GB。 partition_num String Kafka实例的分区数量。
客户端网络环境说明 客户端可以通过以下方式访问Kafka实例： 如果客户端是云上ECS，与Kafka实例处于同region同VPC，则可以直接访问Kafka实例提供的内网连接地址。 如果客户端是云上ECS，与Kafka实例处于相同region但不同VPC，通过以下任意一种方式访问。
支持多语言的客户端。 采用Scala和Java编写，支持多种语言的客户端。 支持多种语言的客户端。 流量控制 RocketMQ 5.x支持基于实例规格的流量控制。 支持client、user和Topic级别，通过主动设置可将流控作用于生产者或消费者。 RabbitMQ的流控基于Credi
engine_version String 版本。 description String 实例描述。 specification String 实例规格。 storage_space Integer 消息存储空间，单位：GB。 partition_num String Kafka实例的分区数量。
访问特定子项目中资源，使得资源的权限控制更加精确。 图1 项目隔离模型 同样在我的凭证下，您可以查看项目ID。 企业项目 企业项目是项目的升级版，针对企业不同项目间资源的分组和管理，是逻辑隔离。企业项目中可以包含多个区域的资源，且项目中的资源可以迁入迁出。 关于企业项目ID的获取
分区列表。 表6 partitions 参数 参数类型 描述 partition_id String 分区ID。 status String 运行状态。 last_transfer_offset String 已转储的消息偏移量。 log_end_offset String 消息偏移量。
IPv4地址：选择“自动分配IPv4地址” 其他参数保持默认，如果想要了解更多的参数信息，请参考购买终端节点。 图5 终端节点参数设置 单击“立即购买”，进入规格确认页面。 确认无误后，提交请求。 购买成功后，返回终端节点页面，查看终端节点状态是否为“已接受”，“已接受”表示终端节点已成功连接至终端节点服务。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
