检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
approval_enabled：输入“false”。 service_type：输入“interface”。 endpoint：获取VPC终端节点的终端节点，区域必须与Kafka实例保持一致。
步骤一：获取Kafka实例的信息 登录管理控制台。 在管理控制台左上角单击，选择Kafka实例所在的区域。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务Kafka版”，进入分布式消息服务Kafka专享版页面。
default_app Boolean 是否为默认应用。 created_time Long 创建时间。 请求示例 查询用户列表。
然后在控制台的“用户管理”页面，获取用户名。 如果需要对指定客户端进行流量控制，请在客户端配置中获取client ID。 如果需要对指定Topic进行流量控制，请在控制台的“Topic管理”页面，获取Topic名称。 创建用户/客户端流控 登录管理控制台。
图1 获取资源ID（实例） 单击实例名称，进入实例详情页，查看存储空间的资源ID。 图2 获取资源ID（存储空间） 进入“费用中心 > 流水和明细账单”页面。 选择“明细账单”，在筛选条件中选择“资源ID”，并输入3复制的资源ID，按“Enter”即可搜索该资源的账单。
URI PUT /v2/{project_id}/instances/{instance_id}/topics 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID，获取方式请参见获取项目ID。
附录 状态码 错误码 实例状态说明 获取项目ID 获取账号名和账号ID
LogAppendTime：broker将消息写入日志的时间。 批处理消息最大值 Kafka允许的最大批处理大小，如果启用消息压缩，则表示压缩后的最大批处理大小。
在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务Kafka版”，进入分布式消息服务Kafka专享版页面。 在左侧导航栏单击“Kafka实例”，进入Kafka实例列表页面。 单击Kafka实例名称，进入实例详情页面。
Kafka设计初衷就是为了应对大量日志传输场景，应用通过异步方式将日志消息同步到消息服务，再通过其他组件对日志做实时或离线分析，也可用于关键日志信息收集进行应用监控。 日志同步主要有三个关键部分：日志采集客户端，Kafka消息队列以及后端的日志处理应用。
（仅源端类型为Kafka时需要填写） consumer_strategy 否 String 启动偏移量，latest为获取最新的数据，earliest为获取最早的数据。
（仅源端类型为Kafka时会显示） topics_mapping String topic映射。
查看SSL证书有效期的方法如下： 解压从Kafka实例控制台下载的压缩包，获取压缩包中的“phy_ca.crt”。 双击“phy_ca.crt”，弹出“证书”对话框。 在“常规”页签中，获取证书有效期。 图1 证书有效期 父主题： 实例问题
URI GET /v2/{project_id}/instances/{instance_id}/topics 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID，获取方式请参见获取项目ID。
（仅源端类型为Kafka时会显示） topics_mapping String topic映射。
project_id 是 String 项目ID，获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 group 是 String 消费组ID。
URI POST /v2/{project_id}/instances/{instance_id}/topics 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID，获取方式请参见获取项目ID。
/v2/{project_id}/instances/{instance_id}/management/topics/{topic}/partitions-reassignment 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID，获取方式请参见获取项目
context.verify_mode = ssl.CERT_REQUIRED ##证书文件，SSL证书参考“收集连接信息”章节获取。如果Kafka安全协议设置为“SASL_PLAINTEXT”，请注释以下参数。
在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务Kafka版”，进入分布式消息服务Kafka专享版页面。 在左侧导航栏单击“Kafka实例”，进入Kafka实例列表页面。 单击Kafka实例的名称，进入实例详情页面。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
