检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
获得Kafka实例的操作权限。具体操作请参考创建用户并授权使用DMS for Kafka。 创建VPC和子网。 在创建Kafka实例前,确保已存在可用的VPC和子网。创建VPC和子网的具体步骤,请参考创建虚拟私有云和子网。 创建的VPC与Kafka实例必须在相同的区域。 创建安全组并添加安全组规则。
"sasl_enabled_mechanisms" : [ "SCRAM-SHA-512", "PLAIN" ] } 响应示例 无 状态码 状态码 描述 200 提交修改Kafka接入方式成功。 错误码 请参见错误码。 父主题: 实例管理
选择需要诊断的消费组名称和Topic名称,单击“诊断前检查”。 检查成功后,在页面上方显示“预检查成功”,并显示内存使用率、CPU利用率、分区订阅关系、消息积压情况和流量突增情况的检查结果。 图2 诊断前检查 “消息积压情况”显示无消息积压时,无法进行消息积压诊断。显示有消息积压,并且消
PLAIN机制、用户名和密码,单击“确定”。跳转到“后台任务管理”页面。当任务状态显示为“成功”时,表示成功开启密文接入。 说明: 首次开启密文接入(包括内网访问密文接入和公网访问密文接入)时,需要设置kafka安全协议、SASL PLAIN机制、用户名和密码,再次开启时,只需要设置kafka安全协议。
使用控制台连接Kafka 本章节介绍Kafka实例如何在控制台生产消息。此功能通过将指定消息发送给Kafka实例,验证业务逻辑是否正常。 前提条件 仅在实例的“状态”为“运行中”时,才可以在Topic中生产消息。 已创建Topic。 在控制台生产消息 登录管理控制台。 在管理控制台左上角单击,选择Kafka实例所在的区域。
回收站策略默认是关闭状态。 约束与限制 回收站中的按需实例不会收取实例的费用,但是会收取存储空间的费用。 包年/包月的实例退订后会存入回收站中,此时不会收取实例的费用,但是会按需收取存储空间的费用。 包年/包月的实例从回收站中恢复后,计费模式会变为按需计费。 处于宽限期和保留期的实例,
功能说明 本章节定义了分布式消息服务Kafka版上报云监控服务的监控指标的命名空间,监控指标列表和维度定义,您可以通过云监控服务的管理控制台或API接口来检索Kafka实例产生的监控指标和告警信息,也可以通过分布式消息服务Kafka版控制台提供的“监控”页面来检索Kafka实例产生的监控指标。
"name": "cluster", "unavailable_zones": [] }] }] } 状态码 操作成功的状态码如表7所示,其他响应见状态码。 表7 状态码 状态码 描述 200 查询规格列表成功。 父主题: 其他接口
消费组问题 Kafka实例是否需要创建消费组、生产者和消费者? 如果消息组中没有在线的消费者(如empty状态),是否14天后会自动被删除? 为什么删除消费组不生效? 实例消费正常,为什么看不到消费者? Kafka可以删除消费组下不用的Topic吗?
Query参数 参数 是否必选 参数类型 描述 engine 是 String 消息引擎的类型。当前只支持Kafka类型。 请求参数 无 响应参数 状态码: 200 表2 响应Body参数 参数 参数类型 描述 Hourly Array of Hourly objects 表示按需付费的产品列表。
Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 批量重启或删除实例成功。 204 删除所有创建失败的Kafka实例成功。 错误码 请参见错误码。 父主题: 生命周期管理
"false", "sync_message_flush": "false" } ] } 状态码 操作成功的状态码如表4所示,其他响应见状态码。 表4 状态码 状态码 描述 200 查询成功。 父主题: 实例管理类接口
"group_subscribed": [ "test-consumer-group" ] } 状态码 查询成功的状态码表5所示,其他响应见表1。 表5 状态码 状态码 描述 200 查询成功。 父主题: 实例使用类接口
31.1.15", "port": 9092 } ] } 状态码 查询成功的状态码如表4所示,其他响应见表1。 表4 状态码 状态码 描述 200 查询成功。 父主题: 实例使用类接口
华为云根据客户等级定义了不同客户的宽限期和保留期时长。 避免和处理欠费 欠费后需要及时充值,详细操作请参见账户充值。 若不再使用Kafka实例,您可以将他们删除,以免继续扣费。 您可以在“费用中心 > 总览”页面设置“可用额度预警”功能,当可用额度、通用代金券和现金券的总额度低于预警阈值时,
参数 类型 说明 id String topic名称 响应示例 { "id": "haha" } 状态码 操作成功的状态码如表4所示,其他响应见状态码。 表4 状态码 状态码 描述 200 创建成功。 父主题: 实例管理类接口
包年/包月转按需,需包年/包月资费模式到期后,按需的资费模式才会生效。 前提条件 Kafka实例计费模式为“包年/包月”。 Kafka实例状态为“运行中”。 在云服务控制台转按需 登录管理控制台。 单击左侧导航栏的图标,选择“应用中间件 > 分布式消息服务Kafka版”。 通过以
"name": "1" }, { "name": "2" }] }] }] } 状态码 查询成功的状态码如表11所示,其他响应见表1。 表11 状态码 状态码 描述 200 查询成功。 父主题: 其他接口
个以上的代理数。 确认“Smart Connect”为开启状态,单击“提交”。 后续操作 开启Smart Connect后,您可以配置Kafka间的数据复制、配置Kafka数据转储至OBS,实现分布式消息服务Kafka版和其他云服务之间的数据同步。 父主题: 使用Smart Connect迁移数据
cluster*3计费。 欠费影响 图3描述了按需计费Kafka实例各个阶段的状态。购买后,在计费周期内Kafka实例正常运行,此阶段为有效期;当您的账号因按需Kafka实例自动扣费导致欠费后,账号将变成欠费状态,Kafka实例将陆续进入宽限期和保留期。 图3 按需计费Kafka实例生命周期 欠费预警