-
Kafka实例批量删除Topic - 分布式消息服务Kafka版
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
-
计费概述 - 分布式消息服务Kafka版
详细介绍请参见计费模式概述。 在购买Kafka实例后,如果发现当前计费模式无法满足业务需求,您还可以变更计费模式。详细介绍请参见变更计费模式概述。 计费项 分布式消息服务Kafka版的计费项由实例费用和存储空间费用组成。了解每种计费项的计费因子、计费公式等信息,请参考计费项。 如
-
基本概念 - 分布式消息服务Kafka版
过程中,您需要用到账号、用户和密码等信息。 区域(Region) 从地理位置和网络时延维度划分,同一个Region内共享弹性计算、块存储、对象存储、VPC网络、弹性公网IP、镜像等公共服务。Region分为通用Region和专属Region,通用Region指面向公共租户提供通用
-
修改实例信息 - 分布式消息服务Kafka版
"description": "instance description", "maintain_begin":"02:00:00", "maintain_end":"06:00:00" } 响应消息 响应参数 无。 响应样例 无。 状态码 操作成功的状态码如表3所示,其他响应见状态码。
-
使用客户端连接Kafka(密文接入) - 分布式消息服务Kafka版
common.security.plain.PlainLoginModule required \ username="**********" \ password="**********"; sasl.mechanism=PLAIN 参数说明: username和
-
分布式消息服务Kafka版 - 分布式消息服务Kafka版
04 使用 根据业务发展需要,您可以为实例扩容存储空间和基准带宽、修改实例安全组、开启实例转储。除此之外,你还可以实时查看监控指标及审计日志,以便及时了解Kafka实例节点、队列、消费组等相关状态。 日常操作 查看实例信息 扩容实例存储空间 扩容实例代理个数 开启Smart Connect
-
Kafka实例批量删除消费组 - 分布式消息服务Kafka版
参数类型 描述 failed_groups Array of failed_groups objects 删除失败的消费组列表。 total Integer 删除失败的个数 表4 failed_groups 参数 参数类型 描述 group_id String 删除失败的消费组ID。
-
批量重启、删除实例 - 分布式消息服务Kafka版
对实例的操作:restart、delete instances Array 否 实例的ID列表。 allFailure String 否 参数值为kafka,表示删除租户所有创建失败的Kafka实例。 请求示例 批量重启实例 POST https://{dms_endpoint}/v1
-
批量重启或删除实例 - 分布式消息服务Kafka版
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
-
查询诊断报告详情 - 分布式消息服务Kafka版
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
-
Kafka数据迁移概述 - 分布式消息服务Kafka版
数据迁移到新的Kafka实例,具体步骤请参考配置Kafka间的数据复制。 需要注意的是,云上Kafka实例为3副本存储,因此建议实例存储空间为原业务的单副本消息存储的3倍。 父主题: 迁移数据
-
重置Kafka Manager密码 - 分布式消息服务Kafka版
重置Manager密码成功,界面提示重置实例的密码成功。 重置Manager密码失败,界面提示重置实例的密码失败,请重新尝试重置密码操作。如果多次重置失败,请联系客服处理。 只有所有代理都重置密码成功,系统才会提示重置密码成功,否则会提示重置失败。 父主题: 管理Kafka Manager
-
制作和替换Kafka的SSL证书 - 分布式消息服务Kafka版
码)。 按照提示信息输入证书拥有者的信息,如姓名、单位、所在城市等。 执行以下命令,创建CA的认证证书。 openssl req -new -x509 -keyout ca-key -out ca-cert -days 3650 按照提示信息输入PEM密码。 按照提示信息输入证书拥有者的信息。
-
查询实例标签 - 分布式消息服务Kafka版
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
-
修改实例信息 - 分布式消息服务Kafka版
Body = &model.UpdateInstanceReq{ MaintainEnd: &maintainEndUpdateInstanceReq, MaintainBegin: &maintainBeginUpdateInstanceReq, Description:
-
欠费说明 - 分布式消息服务Kafka版
如果您在宽限期内仍未支付欠款,那么就会进入保留期,资源状态变为“已冻结”,您将无法对处于保留期的按需计费资源执行任何操作。 保留期到期后,若您仍未支付账户欠款,那么Kafka实例将被释放,数据无法恢复。 图1 按需计费Kafka实例生命周期 华为云根据客户等级定义了不同客户的宽限期和保留期时长。
-
创建Smart Connect任务 - 分布式消息服务Kafka版
需要填写) obs_bucket_name 否 String 转储地址,即存储Topic数据的OBS桶的名称。(仅目标端类型为OBS时需要填写) obs_path 否 String 转储目录,即OBS中存储Topic的目录,多级目录可以用“/”进行分隔。(仅目标端类型为OBS时需要填写)
-
Go - 分布式消息服务Kafka版
的基本信息页面中获取。如果SCRAM-SHA-512和PLAIN都开启了,根据实际情况选择其中任意一种配置连接。如果页面未显示“开启的SASL认证机制”,默认使用PLAIN机制。 非SASL认证方式 package main import ( "bufio" "fmt" "github
-
查询用户/客户端流控配置 - 分布式消息服务Kafka版
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
-
查询Smart Connector任务详情 - 分布式消息服务Kafka版
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great