检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
"domain_id": "accountid", "name": "username", "password": "**********", "email": "email", "description":
内网SASL_PLAINTEXT连接地址 private_sasl_plaintext_domain_name String 内网SASL_PLAINTEXT连接域名 public_plain_enable Boolean 是否开启公网明文开关 public_plain_address
选择：在下拉列表中选择已创建的OBS桶名称，或者单击“创建转储地址”，新创建一个OBS桶。 输入：输入已创建的OBS桶名称，或者单击“创建转储地址”，新创建一个OBS桶。输入的OBS桶必须和Kafka实例在同一个区域。 转储目录 OBS中存储Topic的目录，多级目录可以用“/”进行分隔。
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
内网SASL_PLAINTEXT连接地址 private_sasl_plaintext_domain_name String 内网SASL_PLAINTEXT连接域名 public_plain_enable Boolean 是否开启公网明文开关 public_plain_address
Kafka集群实例 Kafka集群实例规格 Kafka集群实例由三个及以上代理组成，兼容开源Kafka 1.1.0、2.7和3.x。 TPS（Transaction per second），在Kafka场景中，指每秒能写入到Kafka实例的最大消息数量。下表中TPS性能，是指以1
mechanism=SCRAM-SHA-512 #SASL认证机制为“PLAIN”时，配置信息如下。 sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \ username="**********"
配置Kafka自动创建Topic “Kafka自动创建Topic”表示向一个未创建的Topic生产或消费消息时，系统会自动创建此Topic，此Topic的默认参数值如表1所示。 集群实例支持在“配置参数”中修改“log.retention.hours”（老化时间）、“default
如何创建用户、重置用户密码、修改用户信息和删除用户。创建用户后，对Topic进行用户授权的操作，请参见设置Kafka Topic权限。 一个Kafka实例最多创建的用户数量在控制台存在两种限制，一种为20个，另一种为500个，具体以控制台为准。 在控制台创建用户的方法有两种，两种方法对应的重置密码的步骤有区别。
计费样例 计费场景 某用户于2023/03/18 15:30:00在“华北-北京四”区域购买了一个按需计费的Kafka实例，规格配置如下： 规格：kafka.2u4g.cluster*3 总存储空间：高I/O 300GB 用了一段时间后，用户发现Kafka实例当前规格无法满足业务需要，于2023/03/20
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
CPU使用率过高。例如：如果一个消费请求拉取1000条消息，每条都commit，则commit请求TPS是消费的1000倍，消息体越小，这个比例越大。建议隔一定条数或时间，批量commit，或打开enable.auto.commit，这样设置会存在一个缺点，即在客户端故障时，可能
Kafka实例是否支持跨VPC访问？ Kafka实例支持跨VPC访问，您可以通过以下任意一个方式实现跨VPC访问： 创建VPC对等连接，将两个VPC的网络打通，实现跨VPC访问。具体步骤请参考VPC对等连接说明。 利用VPC终端节点在不同VPC间建立跨VPC的连接通道，实现Kaf
费。 统一包年/包月资源的到期日 如果您持有多台到期日不同的Kafka实例，可以将到期日统一设置到一个日期，便于日常管理和续费。 图5展示了用户将两个不同时间到期的资源，同时续费一个月，并设置“统一到期日”后的效果对比。 图5 统一到期日 更多关于统一到期日的规则请参见如何设置统一到期日。
重置Kafka Manager密码 如果您忘记了创建实例时设置的Kafka Manager密码，通过重置Manager密码功能，重新设置一个新的密码，可使用新密码登录Kafka Manager。 2023年5月17日及以后创建的实例不提供重置Kafka Manager密码功能。 前提条件
业务数据不均衡处理建议 方案概述 Kafka将Topic划分为多个分区，所有消息分布式存储在各个分区上。每个分区有一个或多个副本，分布在不同的Broker节点上，每个副本存储一份全量数据，副本之间的消息数据保持同步。Kafka的Topic、分区、副本和代理的关系如下图所示： 在实
包年/包月转按需 创建一个包年/包月Kafka实例后，您可以将该Kafka实例的计费模式转为按需计费，回收部分成本，同时更加灵活地按需使用Kafka实例。 包年/包月转按需，需包年/包月资费模式到期后，按需的资费模式才会生效。 前提条件 Kafka实例计费模式为“包年/包月”。 Kafka实例状态为“运行中”。
分布式消息服务Kafka版”，进入分布式消息服务Kafka专享版页面。 通过以下任意一种方法，重启Kafka实例。 勾选Kafka实例名称左侧的方框，可选一个或多个，单击信息栏左上侧的“重启”。 在待重启Kafka实例所在行，单击“重启”。 单击Kafka实例名称，进入实例详情页面。单击右上角的“重启”。
成长地图 | 华为云 分布式消息服务Kafka版 分布式消息服务Kafka版（Distributed Message Service for Kafka）是一款基于开源社区版Kafka提供的消息队列服务，向用户提供计算、存储和带宽资源独占式的Kafka专享实例。 免费体验 图说Kafka
靠性，支持消息查询、消息迁移等高级特性。 功能不完善，需额外投入进行开发。 稳定可靠 稳定高可用 支持跨AZ部署，提升可靠性。故障自动发现并上报告警，保证用户关键业务的可靠运行。 需要自己开发或基于开源实现，开发成本高昂，无法保证业务可靠运行。 无忧运维 后台运维对租户完全透明，
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
