查询Kafka集群元数据信息 功能介绍 查询Kafka集群元数据信息。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/instances/{instance_id}/management/cluster 表1 路径参数 参数 是否必选 参数类型

查看更多 →

查询Kafka集群元数据信息 当前页面API为历史版本API，未来可能停止维护。请使用查询Kafka集群元数据信息。 URI GET /v1.0/{project_id}/instances/{instance_id}/manage/cluster 参数说明如下表所示。 表1 参数说明

查看更多 →

topic_id String 产品主题ID。 最小长度：1 最大长度：99999999999999999 permission Integer 主题权限，0-发布，1-订阅。 最小值：0 最大值：10 topic_name String 主题名称。 最小长度：0 最大长度：64

查看更多 →

更新主题策略 功能介绍 更新主题的策略信息。 调用方法 请参见如何调用API。 URI PUT /v2/{project_id}/notifications/topics/{topic_urn}/attributes/{name} 表1 路径参数 参数 是否必选 参数类型 描述 project_id

查看更多 →

RS可以直接选择相应的订阅主题。 如果用户未创建和订阅SMN主题，需要先创建主题，作为发送消息和订阅通知的信道，为发布者和订阅者提供一个可以相互交流的通道。然后添加订阅并请求订阅，这样，订阅用户的华为账号冻结时才能够将告警信息通过主题发送给订阅这个主题的订阅者。完成创建和添加订阅

查看更多 →

发布主题消息简介 消息通知服务提供了以下三种通用的方式。 发布文本格式的消息。 发布JSON格式的消息。 发布模板格式的消息。 一旦一条新的消息已经发布，消息通知服务试图将消息发布至每个已经向主题确认订阅的终端节点。 如果使用短信协议接收消息，对于内容很长的消息，短信长度限制为4

查看更多 →

创建消息通知主题后，只有在订阅队列上创建的Spark作业失败时才会收到消息通知。 图2 创建主题成功 单击图2中“主题管理”，跳转至消息通知服务“主题管理”页面。 图3 主题管理 在对应主题的“操作”列中，单击“添加订阅”，选择“协议”，确定订阅方式。 如果选择“短信”协议，需要在“订阅终端”中填写接收确认短信的手机号码。

查看更多 →

数据库存储 DDS使用的的存储配置是什么 数据超过了文档数据库实例的最大存储容量怎么办 什么是DDS实例的只读状态？

查看更多 →

Hive ORC数据存储优化 操作场景 “ORC”是一种高效的列存储格式，在压缩比和读取效率上优于其他文件格式。 建议使用“ORC”作为Hive表默认的存储格式。 前提条件 已登录Hive客户端，具体操作请参见Hive客户端使用实践。 操作步骤 推荐：使用“SNAPPY”压缩，适用于压缩比和读取效率要求均衡场景。

查看更多 →

账单数据存储（旧版） 下载订阅的账单 资源消费记录 流水详单 资源详单 对账单 父主题： 附录

查看更多 →

数据库存储 数据超过了 GaussDB 实例的最大存储容量怎么办 如何查看GaussDB的存储空间使用情况

查看更多 →

数据多样化存储 云数据库RDS支持与分布式缓存服务Redis版、GeminiDB (Redis接口)和对象存储服务等存储产品搭配使用，实现多样化存储扩展。 图1 数据库多样化存储 父主题： 典型应用

查看更多 →

Kafka数据源连接失败 原因分析 连接地址填写的是MQS内网地址，且MQS同时开启了SSL与VPC内网明文访问时，“是否SSL”选择了“是”。 解决方案 修改“是否SSL”为“否”。 如果排除以上问题后，仍然连接失败，可参考数据源连接测试失败排查操作进行问题排查。 父主题： 数据源

查看更多 →

作请参考增加Kafka Topic分区。 在“Topic Rank”栏，可查看当前集群Topic日志条数、数据体积大小、数据流入量、数据流出量前十名的Topic。 单击“TopicName”可进入到该Topic的详情页面中，在该页面的具体操作请参考查看Kafka数据生产消费详情。

查看更多 →

除。 系统默认内置的Topic不支持删除操作。 查看生产数据条数。 在“Producer Message”栏可选择“Day”、“Week”、“Month”不同时段查看当前集群所有集群生产数据条数。 父主题： 管理Kafka Topic

查看更多 →

）。 已安装Kafka客户端。 Kafka实例状态和磁盘状态均正常。 根据待迁移分区当前的磁盘空间占用情况，评估迁移后，不会导致新迁移后的磁盘空间不足。 使用Kafka客户端迁移数据 以客户端安装用户，登录已安装Kafka客户端的节点。 执行以下命令，切换到Kafka客户端安装目

查看更多 →

接入 MRS Kafka数据源 概述 ROMA Connect支持把MRS Kafka作为一个数据源，并用于数据集成任务。在使用MRS Kafka数据源前，您需要先接入数据源。 前提条件 每个接入的数据源都要归属到某个集成应用下，在接入数据源前您需要有可用的集成应用，否则请提前创建集成应用。

查看更多 →

转储目录 OBS中存储Topic的目录，多级目录可以用“/”进行分隔。 时间目录格式 数据将存储在转储目录下的时间目录中，时间目录是按时间格式作为层级的目录。例如，当选择的时间目录格式精确到日时，存储目录为：“桶名称/转储目录/年/月/日”。 记录分隔符 在下拉列表中选择一种分隔符，分隔不同的转储记录。

查看更多 →

同步Kafka数据至ClickHouse 本章节指导用户通过创建Kafka引擎表将Kafka数据自动同步至ClickHouse集群。 前提条件 已创建Kafka集群。已安装Kafka客户端，详细可以参考安装客户端。 已创建ClickHouse集群，并且ClickHouse集群和K

查看更多 →

）。 已安装Kafka客户端。 Kafka实例状态和磁盘状态均正常。 根据待迁移分区当前的磁盘空间占用情况，评估迁移后，不会导致新迁移后的磁盘空间不足。 使用Kafka客户端迁移数据 以客户端安装用户，登录已安装Kafka客户端的节点。 执行以下命令，切换到Kafka客户端安装目

查看更多 →

Kafka Kafka是一个分布式流处理平台，最初由LinkedIn开发。它是一个高吞吐量、低延迟的平台，可以处理大量的实时数据流。Kafka主要由三个部分组成：生产者、消费者和代理 服务器 。生产者将数据发布到Kafka集群，消费者从Kafka集群订阅数据并进行处理，代理服务器则是

查看更多 →