检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
Connect 开启Smart Connect功能。 关闭Smart Connect 关闭Smart Connect功能。 变更规格 扩容存储空间 扩容代理数量 扩容基准带宽 扩容代理规格 缩容代理规格 创建流控 创建用户/客户端/Topic流控。 编辑流控 修改流控参数。 删除流控
Kafka权限，不满足您的授权要求，可以创建自定义策略。自定义策略中可以添加的授权项（Action）请参考细粒度策略支持的授权项。 目前华为云支持以下两种方式创建自定义策略： 可视化视图创建自定义策略：无需了解策略语法，按可视化视图导航栏选择云服务、操作、资源、条件等策略内容，可自动生成策略。
实例规格。 storage_space Integer 消息存储空间，单位：GB。 partition_num String Kafka实例的分区数量。 used_storage_space Integer 已使用的消息存储空间，单位：GB。 dns_enable Boolean 实例是否开启域名访问功能。
有可用资源的可用区列表。 表5 detail 参数 参数类型 描述 tps String 单位时间内的消息量最大值。 storage String 消息存储空间。 partition_num String Kafka实例的分区数量。 product_id String 产品ID。 spec_code
设置存储Topic数据的OBS桶的名称。 选择：在下拉列表中选择已创建的OBS桶名称，或者单击“创建转储地址”，新创建一个OBS桶。 输入：输入已创建的OBS桶名称，或者单击“创建转储地址”，新创建一个OBS桶。输入的OBS桶必须和Kafka实例在同一个区域。 转储目录 OBS中存储Topi
与其他云服务的关系 云审计（Cloud Trace Service） 云审计为您提供云服务资源的操作记录，记录内容包括您从管理控制台或者开放API发起的云服务资源操作请求以及每次请求的结果，供您查询、审计和回溯使用。 当前CTS记录的操作，请参考云审计日志。 虚拟私有云（Virtual
息数据迁移到新的Kafka实例，具体步骤请参考配置Kafka间的数据复制。 需要注意的是，云上Kafka实例为3副本存储，因此建议实例存储空间为原业务的单副本消息存储的3倍。 父主题： 迁移数据
然后提供Java、Python和Go等语言的连接示例。 本指南的示例仅展示Kafka的API调用，生产与消费的API集，请参考Kafka官网。 客户端网络环境说明 客户端可以通过以下方式访问Kafka实例： 如果客户端是云上ECS，与Kafka实例处于同region同VPC，则
IdentityReplicationPolicy”。 在源集群生产并消费消息，在目标集群查看消费进度，确认数据是否已从源集群同步到了目标集群。 如果目标集群为华为云Kafka实例的话，在分布式消息服务Kafka版控制台的“消费组管理 > 消费进度”中，查看消费进度。
实例规格。 storage_space Integer 消息存储空间，单位：GB。 partition_num String Kafka实例的分区数量。 used_storage_space Integer 已使用的消息存储空间，单位：GB。 dns_enable Boolean 实例是否开启域名访问功能。
实例规格。 storage_space Integer 消息存储空间，单位：GB。 partition_num String Kafka实例的分区数量。 used_storage_space Integer 已使用的消息存储空间，单位：GB。 dns_enable Boolean 实例是否开启域名访问功能。
Kafka实例的detail参数说明 参数 类型 说明 tps String 单位时间内的消息量最大值。 storage String 消息存储空间。 partition_num String Kafka实例的最大Topic数。 product_id String 产品ID。 spec_code
个partition的一个请求。 较小的批量处理数值比较少用，并且可能降低吞吐量（0则会仅用批量处理）。较大的批量处理数值将会浪费更多内存空间，这样就需要分配特定批量处理数值的内存大小。 buffer.memory 33554432 67108864 producer可以用来缓存
ka实例列表页面。 Kafka实例支持通过筛选来查询对应的Kafka实例。当前支持的筛选条件为标签、状态、名称、版本、规格、已用/可用存储空间、分区上限、计费模式和企业项目。企业用户才能使用企业项目进行筛选。Kafka实例状态请参见表1。 表1 Kafka实例状态说明 状态 说明
指标名称 测量对象 告警策略 指标说明 告警处理建议 broker_disk_usage 磁盘容量使用率 节点 告警阈值：原始值>80% 连续触发次数：1 告警级别：紧急 该指标为从Kafka节点虚拟机层面采集的磁盘容量使用率。 出现该告警时，需要修改实例存储空间。具体操作，请参考变更实例规格。
is " + i; // 注意填写您创建的topic名称。另外，生产消息的API有多个，具体参见Kafka官网或者下文的生产消息代码。 producer.produce("topic-0", partition, key
er的可用磁盘容量。如果目标Broker磁盘剩余容量接近分区平衡迁移到该Broker上的数据量，为了给目标Broker上的消息生产预留存储空间，应先进行磁盘扩容，再进行分区平衡。 使用自动平衡修改副本数 登录管理控制台。 在管理控制台左上角单击，选择Kafka实例所在的区域。 在管理控制台左上角单击，选择“应用中间件
区域：华北-北京四 可用区：可用区1 版本：2.7 部署架构：集群 代理规格：kafka.2u4g.cluster 代理数量：3 单代理存储空间：超高I/O，200GB 虚拟私有云：选择虚拟私有云 子网：选择子网 安全组：选择安全组 访问方式：保持默认 实例名称：kafka-test
告警级别 选择“重要”。 通知类型 选择“触发”，即触发告警时发送通知。 接收对象 选择“主题订阅”，单击“创建主题”，进入消息通知服务中，创建主题和添加订阅。创建完成后，返回“创建告警规则”页面，在“通知对象”后单击，然后选择创建的告警通知主题。 说明： 在添加订阅后，对应的订阅终
开启Smart Connect Smart Connect用于Kafka实例和其他云服务（如OBS）之间的数据同步，或者两个Kafka实例之间的数据同步，实现数据的备份或迁移。 Smart Connect的使用流程为： 开启Smart Connect。 创建Smart Connect任务。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
