DMS输入流 分布式消息服务（Distributed Message Service，简称DMS）是一项基于高可用分布式集群技术的消息中间件服务，提供了可靠且可扩展的托管消息队列，用于收发消息和存储消息。 分布式消息服务Kafka是一款基于开源社区版Kafka提供的消息队列服务，向用户

查看更多 →

Kafka业务使用流程 分布式消息服务Kafka版是一款基于开源社区版Kafka提供的消息队列服务，向用户提供计算、存储和带宽资源独占式的Kafka实例。使用Kafka实例生产消费消息的流程如下图所示。 图1 Kafka业务使用流程 创建用户并授权使用DMS for Kafka 创建IAM用户，并授予DMS

查看更多 →

如何获取分布式消息服务Kafka实例的SASL证书地址？ 用户在创建事件流，配置事件源为分布式消息服务Kafka版实例时，当Kafka实例开启SASL SSL时，需要输入SASL证书地址。 本章节介绍如何获取Kafka实例的SASL证书地址。 操作步骤 下载Kafka实例的SSL证书。

查看更多 →

理的速度。 在partition数据均匀分布的情况下，同时提高partition和executor个数，将会提升Spark处理速度（当partition个数和executor个数保持一致时，处理速度是最快的）。 在partition数据均匀分布的情况下，尽量保持partition

查看更多 →

消息 发起聊天 查看消息 文件传输助手 父主题： 普通用户指南（app）

查看更多 →

发布消息事件 登录圆桌。 选择创建入口。 个人创建入口 在选择团队页面选择“ME”团队，进入个人团队页面。 团队创建入口 在选择团队页面选择具体团队，进入团队页面。 在团队页面，单击右上角的，进入发布事件页面，选择“消息”。 在“消息”创建页面，输入消息内容。 图1 消息事件 发布设置和高级设置，具体设置请参见创建事件。

查看更多 →

消息。支持显示已读/未读消息。 合并转发IM消息 右键单击某条消息，选择“多选”，勾选要转发的消息，点击“合并转发”，选择要转发的人或者群聊，最终结果将以卡片形式呈现。 消息文件支持断点续传 通过消息发送、下载文件，因网络中断或手动取消时，可按原来的进度继续发送、下载文件。 智能搜索

查看更多 →

消息 概述 添加应用模板 创建事件 预置数据 查看应用模板详情 常用事件模板 事件管理 父主题： 圆桌门户用户指南

查看更多 →

，针对未读人员可再次提醒。 发布消息事件 登录圆桌。 选择创建入口。 个人创建入口 在左侧栏选择“消息”模块，进入个人“消息”页面。 团队创建入口 在左侧栏选择团队，单击“消息”页签。 单击“新建”右侧的，选择“消息”。 在“消息”弹窗，输入消息内容，支持上传图片，视频，附件等多类富文本。

查看更多 →

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

查看更多 →

Kafka Kafka jar包冲突列表 Jar包名称 描述 kafka_2.11-*.jar 连接Kafka服务必须的jar包。 kafka-clients-*.jar 连接Kafka服务必须的jar包。 解决方案 Kafka不建议使用开源版本的包。 父主题： MRS 应用开发开源jar包冲突列表说明

查看更多 →

Kafka Kafka基本原理 Kafka与其他组件的关系 Kafka开源增强特性 父主题： 组件介绍

查看更多 →

Kafka监控显示消息堆积数跟实例里的消息数不一致？ 问题现象：监控显示消息堆积数为8.1亿+，Kafka控制台显示实例中6个Topic的消息数总和为1亿+，两者不一致。 问题结论：两者统计方式不同，Kafka控制台显示的消息数为实例中未消费的消息个数，而监控显示的消息堆积数=Topic中的消息积压数*消费组数。

查看更多 →

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

查看更多 →

理的速度。 在partition数据均匀分布的情况下，同时提高partition和executor个数，将会提升Spark处理速度（当partition个数和executor个数保持一致时，处理速度是最快的）。 在partition数据均匀分布的情况下，尽量保持partition

查看更多 →

消息 通话记录哪里找？ 移动端如何转发聊天记录？ 如何发文件给对方？ 如何快速定位到未读消息？ 消息聊天对话框如何置顶？ 如何查看移动端的历史聊天记录？ 如何开启/关闭 WeLink 的消息通知？ WeLink没有消息提醒？ 消息首页输入一个字符搜索，没有结果？ WeLink能不能@某人及某条内容

查看更多 →

图片，消息和云空间里暂不支持）等文件下载到本地，还可复制文本信息，并粘贴到其他应用。 云端存储IM消息 当前IM消息云端存储周期为90天，企业可通过购买消息存储周期服务套餐将存储周期延长至180天、360天、720天。 同步聊天记录 点击个人头像，在“设置＞应用设置＞消息”界面，

查看更多 →

消息 发起1对1聊天 群聊管理 消息管理 文件传输助手 父主题： 普通用户指南（web）

查看更多 →

频点播、视频监控等多种数据存储场景。 OBS提供了标准存储、低频访问存储、归档存储、深度归档存储（受限公测中）四种存储类别，满足不同场景下客户对存储性能和成本的不同诉求。 分布式消息服务Kafka版（DMS） 分布式消息服务Kafka版（Distributed Message Service

查看更多 →

的目的端，把设备上报的数据转发到DIS。 分布式消息服务 Kafka 分布式消息服务 Kafka（Distributed Message Service for Kafka，简称Kafka）是一款基于开源社区版Kafka提供的消息队列服务，是一个拥有高吞吐、可持久化、可水平扩展，

查看更多 →

DRS发送Kafka消息序列化方式是什么 DRS发送到Kafka的数据，key序列化器是org.apache.kafka.common.serialization.StringSerializer，value序列化器是org.apache.kafka.common.serialization

查看更多 →