-
使用VPCEP实现跨VPC访问Kafka - 分布式消息服务Kafka版
区域:与Kafka实例保持一致。 服务类别:选择“按名称查找服务”。 服务名称:输入8中记录的终端节点服务名称,单击“验证”。显示“已找到服务”后,继续后续操作。 虚拟私有云:选择Kafka客户端所属的VPC。 子网:选择Kafka客户端所属的子网。 IPv4地址:选择“自动分配IPv4地址”
-
Java开发环境搭建 - 分布式消息服务Kafka版
password为服务器证书密码,配置此密码是为了访问Java生成的jks文件。 ssl.truststore.password=dms@kafka #ssl.endpoint.identification.algorithm为证书域名校验开关,为空则表示关闭,这里需要保持关闭状态,必须设置为空。
-
欠费说明 - 分布式消息服务Kafka版
欠费说明 用户在使用云服务时,账户的可用额度小于待结算的账单,即被判定为账户欠费。欠费后,可能会影响云服务资源的正常运行,请及时充值。 欠费原因 购买了按需计费Kafka实例,并使用了一段时间后,账户的余额不足。 欠费影响 包年/包月 对于包年/包月Kafka实例,用户已经预先支
-
查询指定实例 - 分布式消息服务Kafka版
storage_resource_id String 存储资源ID。 storage_spec_code String IO规格。 service_type String 服务类型。 storage_type String 存储类型。 retention_policy String 消息老化策略。 kafka_public_status
-
查看和修改Kafka实例基本信息 - 分布式消息服务Kafka版
在管理控制台左上角单击,选择区域。 请选择Kafka实例所在的区域。 在管理控制台左上角单击,选择“应用中间件 > 分布式消息服务Kafka版”,进入分布式消息服务Kafka专享版页面。 Kafka实例支持通过筛选来查询对应的Kafka实例。当前支持的筛选条件为标签、状态、名称、版本、
-
修改实例跨VPC访问的内网IP - 分布式消息服务Kafka版
fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 修改实例跨VPC访问的内网IP成功。 错误码 请参见错误码。 父主题: 实例管理
-
配置Kafka实例的明文/密文接入 - 分布式消息服务Kafka版
在管理控制台左上角单击,选择“应用中间件 > 分布式消息服务Kafka版”,进入分布式消息服务Kafka专享版页面。 单击Kafka实例的名称,进入实例的“基本信息”页面。 密文接入分为内网访问密文接入和公网访问密文接入,关闭密文接入方法如表5所示。 表5 关闭密文接入方法 接入方式 关闭明文接入 内网访问密文接入
-
查询指定实例 - 分布式消息服务Kafka版
storage_resource_id String 存储资源ID。 storage_spec_code String IO规格。 service_type String 服务类型。 storage_type String 存储类型。 retention_policy String 消息老化策略。 kafka_public_status
-
包年/包月 - 分布式消息服务Kafka版
格为准。 图2 包年/包月Kafka实例费用计算示例(华北-北京四区域) 变更配置后对计费的影响 当前包年/包月Kafka实例资源的规格不满足您的业务需要时,您可以在Kafka实例控制台发起变更规格操作,变更时系统将按照如下规则为您计算变更费用: 资源升配:新配置价格高于老配置价格,此时您需要支付新老配置的差价。
-
Java客户端接入示例 - 分布式消息服务Kafka版
password为服务器证书密码,配置此密码是为了访问Java生成的jks文件。 ssl.truststore.password=dms@kafka #ssl.endpoint.identification.algorithm为证书域名校验开关,为空则表示关闭,这里需要保持关闭状态,必须设置为空。
-
查询所有实例列表 - 分布式消息服务Kafka版
storage_resource_id String 存储资源ID。 storage_spec_code String IO规格。 service_type String 服务类型。 storage_type String 存储类型。 retention_policy String 消息老化策略。 kafka_public_status
-
单机和集群Kafka实例差异概述 - 分布式消息服务Kafka版
单机和集群Kafka实例差异概述 单机版实例是分布式消费服务Kafka版提供的单代理实例,只适用体验和业务测试场景,无法保证性能和可靠性。如果需要在生产环境使用Kafka实例,建议购买集群实例。 单机版实例当前仅在“华东-上海一”和“华南-广州-友好用户环境”区域上线。 购买实例时的参数区别
-
修改实例信息 - 分布式消息服务Kafka版
该参数不能单独为空,若该值为空,则结束时间也为空。系统分配一个默认开始时间02:00:00。 maintain_end String 否 维护时间窗结束时间,格式为HH:mm:ss。 维护时间窗开始和结束时间必须为指定的时间段,可参考查询维护时间窗时间段。 结束时间在开始时间基础上加四个小时,即当开始时间为22
-
查询所有实例列表 - 分布式消息服务Kafka版
storage_resource_id String 存储资源ID。 storage_spec_code String IO规格。 service_type String 服务类型。 storage_type String 存储类型。 retention_policy String 消息老化策略。 kafka_public_status
-
变更Kafka实例规格 - 分布式消息服务Kafka版
请选择Kafka实例所在的区域。 在管理控制台左上角单击,选择“应用中间件 > 分布式消息服务Kafka版”,进入分布式消息服务Kafka专享版页面。 在Kafka实例所在行,单击“更多 > 变更规格”,进入“分布式消息服务Kafka版变更规格”页面。 根据实际情况选择扩容存储空间、代理数量、代理规格、基准带宽,或者缩容代理规格。
-
【下线公告】华为分布式消息服务Kafka版2.3.0版本停售公告 - 分布式消息服务Kafka版
【下线公告】华为分布式消息服务Kafka版2.3.0版本停售公告 华为云计划于2023/05/05 00:00(北京时间)停售分布式消息服务Kafka版2.3.0版本。 下线范围 下线区域:所有区域 下线影响 该版本停售后,新用户将无法进行购买,已购买该版本的用户不受影响,可继续使用扩容等功能。
-
重置消费组消费进度到指定位置 - 分布式消息服务Kafka版
在停止被重置消费组客户端后,需要经过ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG配置的时间(默认10000毫秒),服务端才认为消费组客户端真正下线。 URI POST /v1.0/{project_id}/instances/{instanc
-
查询消息 - 分布式消息服务Kafka版
以及数字。 asc 否 Boolean 是否按照时间排序。 start_time 否 String 开始时间。 Unix毫秒时间戳。 查询消息偏移量时,为必选参数。 end_time 否 String 结束时间。 Unix毫秒时间戳。 查询消息偏移量时,为必选参数。 limit 否
-
权限和授权项 - 分布式消息服务Kafka版
组授予策略或角色,才能使用户组中的用户获得相应的权限,这一过程称为授权。授权后,用户就可以基于已有权限对云服务进行操作。 权限根据授权的精细程度,分为角色和策略。角色以服务为粒度,是IAM最初提供的一种根据用户的工作职能定义权限的粗粒度授权机制。策略以API接口为粒度进行权限拆分
-
Kafka的消费组删除了,怎么监控页面还可以看到这个消费组? - 分布式消息服务Kafka版
组? 监控数据是每分钟进行采集上报,上报的数据经过整理后才会显示在监控页面上,此过程大约需要几分钟到十几分钟,建议您在删除消费组后,过一段时间再去监控页面查看。 父主题: 监控告警问题