检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
范围8到2400，且必须为实例节点个数的倍数。 publicip_id String 否 实例绑定的弹性IP地址的ID。 以英文逗号隔开多个弹性IP地址的ID。 如果开启了公网访问功能（即enable_publicip为true），该字段为必选。 ssl_enable Boolean
--all-groups 参数说明如下：connection-address表示Kafka实例的连接地址，在Kafka控制台的“基本信息 > 连接信息”中获取。 示例如下： [root@ecs-kafka bin]# ./kafka-consumer-groups.sh --bootstrap-server
前提条件 已准备一台Linux系统的服务器，并安装Java Development Kit 1.8.111或以上版本，配置JAVA_HOME与PATH环境变量。 实例已开启Kafka SASL_SSL。 步骤一：制作证书 登录Linux系统的服务器，执行以下命令，生成server.keystore
生产者列表 表4 producers 参数 参数类型 描述 producer_address String 生产者地址 broker_address String broker地址 join_time Long 加入时间 请求示例 查询Topic的当前生产者列表 GET https://
SmartConnectTaskRespSourceConfig 参数 参数类型 描述 redis_address String Redis实例地址。（仅源端类型为Redis时会显示） redis_type String Redis实例类型。（仅源端类型为Redis时会显示） dcs_instance_id
单击“下载”，下载连接实例的SSL证书。 内网连接地址 未开启公网访问时，连接实例的地址。 显示的连接地址个数为实例代理个数。 Manager内网访问地址 未开启公网访问时，连接Kafka Manager的地址。 2023年5月17日及以后创建的实例不提供此地址。 Manager用户名 连接Kafka
SmartConnectTaskReqSourceConfig 参数 是否必选 参数类型 描述 redis_address 否 String Redis实例地址。（仅源端类型为Redis时需要填写） redis_type 否 String Redis实例类型。（仅源端类型为Redis时需要填写） dcs_instance_id
SmartConnectTaskRespSourceConfig 参数 参数类型 描述 redis_address String Redis实例地址。（仅源端类型为Redis时会显示） redis_type String Redis实例类型。（仅源端类型为Redis时会显示） dcs_instance_id
Transfer）风格API，支持您通过HTTPS请求调用，调用方法请参见如何调用API。 终端节点 终端节点（Endpoint）即调用API的请求地址，不同服务不同区域的终端节点不同，您可以从地区和终端节点中查询所有服务的终端节点。 基本概念 账号 用户注册时的账号，账号对其所拥有的资源
消息/邮件。 代理（Broker） 即Kafka集群架构设计中的单个Kafka进程，一个Kafka进程对应一台服务器，因此手册中描述的代理，还包括对应的存储、带宽等服务器资源。 分区（Partition） 为了实现水平扩展与高可用，Kafka将Topic划分为多个分区，消息被分布式存储在分区中。
创建用户 授权用户 消费组管理 分布式消息服务Kafka版支持在控制台删除消费组、重置消费进度以及查看消费者连接地址。 支持区域： 全部 删除消费组 重置消费进度 查看消费者连接地址 修改配置参数 分布式消息服务Kafka版为实例、Topic、消费者提供了几个常用配置参数的默认值，您可以
连接信息”中，获取Kafka实例的连接地址。 number-of-partitions：Topic的分区数。出于性能考虑，建议单个Topic的分区数设置为200以内。 number-of-replicas：Topic的副本数。 示例如下： [root@ecs-kafka bin]# ./kafka-topics
assignment_strategy String 分区分配策略。 表4 members 参数 参数类型 描述 host String 消费组consumer地址。 assignment Array of assignment objects consumer分配到的分区信息。 member_id String
当分区中的消息都已老化，或尚未生产消息时，“最早更新时间”和“最近更新时间”显示“--”，如下图所示。 图2 分区信息 生产者信息：包含Broker地址、生产者地址和加入时间。 2023年7月10日以及之前创建的Topic，在Topic详情页面不显示“生产者”页签。 图3 生产者信息 父主题： Topic管理
获取SK的方法，具体请参见新增访问密钥。 转储地址 设置存储Topic数据的OBS桶的名称。 选择：在下拉列表中选择已创建的OBS桶名称，或者单击“创建转储地址”，新创建一个OBS桶。 输入：输入已创建的OBS桶名称，或者单击“创建转储地址”，新创建一个OBS桶。输入的OBS桶必须和Kafka实例在同一个区域。
vpc:ports:get vpc:subnets:get vpc:vpcs:list vpc:publicIps:get vpc:publicIps:list vpc:ports:update vpc:publicIps:update vpc:ports:delete dms:instance:getBackgroundTask
区。 是否支持Kerberos认证 不支持 客户端单IP连接数 2020年7月以及之后购买的实例，Kafka实例的每个代理允许客户端单IP连接的个数默认为1000个，在此之前购买的实例，Kafka实例的每个代理允许客户端单IP连接的个数默认为200个，如果超过了，会出现连接失败问题。
great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted
descriptionUpdateInstanceReq:= "kafka description" nameUpdateInstanceReq:= "kafka001" request.Body = &model.UpdateInstanceReq{ Description:
开源Kafka 简单易用 立等可用 即开即用，可视化操作，自助创建，自动化部署，分钟级创建实例，立即使用，实时查看和管理消息实例。 自行准备服务器资源，安装配置必要的软件并进行配置，等待时间长。 易出错。 简单API 提供简单的实例管理RESTful API，使用门槛低。 无 成本低廉
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
