通过公网访问Kafka（开启SSL加密）。 关闭公网访问（不支持修改SASL开关） 登录管理控制台。 在管理控制台左上角单击，选择区域。 请选择Kafka实例所在的区域。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务Kafka版”，进入分布式消息服务Kafka专享版页面。

查看更多 →

规格推荐 独享节点规格推荐 应用服务网格性能与集群控制面（Master）节点资源息息相关，请您根据您的业务需求，选择合适的独享节点规格，以提高应用服务网格的可用性。 QPS（每秒请求数）总数 0~20000 20000~60000 节点规格 8U16G 16U32G 其中QPS总

查看更多 →

WeLink 推荐 平台推送的知识内容统一归纳到WeLink推荐栏目，企业可以自由选择订阅平台推送内容，可以删除WeLink官方推荐的内容或选择订阅指定分类内容。 文章列表 企业管理员可删除WeLink官方推荐的内容。 在“知识”下拉菜单选择“知识”，进入 知识管理 界面。单击“WeLink推荐”>

查看更多 →

在推荐实例列表，勾选需要编辑的推荐实例，单击列表上方的“编辑”。 批量删除推荐实例 在推荐实例列表，勾选需要删除的推荐实例，单击列表上方的“删除”。 使推荐实例生效 在推荐实例列表，勾选一个或多个需要生效的推荐实例，单击列表上方的“生效”。 使推荐实例失效 在推荐实例列表，勾选一个或多个需要失效的推荐实例，单击列表上方的“失效”。

查看更多 →

API（推荐） 引擎版本和规格 磁盘管理 实例管理 参数配置 版本升级 备份恢复管理 日志管理 管理数据库和用户 标签管理 配额管理 任务管理 回收站 插件管理

查看更多 →

可用区ID。 score Integer 推荐分数。 请求示例 设置对云服务器资源供给的地域和规格推荐，vCPU范围为2~8，内存范围为4096 MiB~8192 MiB；推荐结果对每个可用区下的每个规格打分，推荐策略为成本策略，接受推荐的区域为“region1”。 POST h

查看更多 →

原因4：设备上配置了风暴控制的接口数超过推荐的阈值 设备上配置了风暴控制的接口数超过推荐的阈值，设备打印告警信息提示用户当前的配置已经超过推荐值。用户可以根据实际需求选择是否修改当前的配置。 原因5：设备上配置了sFlow功能的接口数超过推荐的阈值。 设备上配置了sFlow功能的接口数超过推荐的阈值，设备打

查看更多 →

已开启Smart Connect。 已创建Kafka实例，且实例状态为“运行中”。 已创建的OBS桶和Kafka实例需要在同一个区域。 配置Kafka数据转储至OBS 登录管理控制台。 在管理控制台左上角单击，选择区域。 请选择Kafka实例所在的区域。 在管理控制台左上角单击，选择“应用中间件

查看更多 →

开启/关闭SSL双向认证将重启实例，请谨慎操作。 配置SSL双向认证的流程如图1所示。 图1 配置SSL双向认证流程图 前提条件 已准备一台Linux系统的 服务器 。 实例已开启Kafka SASL_SSL。 步骤一：制作客户端验证服务端的证书 登录Linux系统的服务器，执行以下命令，生成server.keystore

查看更多 →

ka服务端配置。 已安装Kafka客户端。 操作步骤 以客户端安装用户，登录安装Kafka客户端的节点。 切换到Kafka客户端安装目录，例如“/opt/client”。 cd /opt/client 执行以下命令，配置环境变量。 source bigdata_env 执行以下命令，进行用户认证。

查看更多 →

已安装Kafka客户端。 操作步骤 以客户端安装用户，登录安装Kafka客户端的节点。 切换到Kafka客户端安装目录，例如“/opt/client”。 cd /opt/client 执行以下命令，配置环境变量。 source bigdata_env 执行以下命令，进行用户认证。 kinit 组件业务用户

查看更多 →

使用kubectl（推荐） kubectl配置指南 cci-iam-authenticator使用参考

查看更多 →

arrange_infos Array of TaskBaseBody objects 参数解释： 部署任务列表。 表5 TaskBaseBody 参数 参数类型 描述 id String 参数解释： 部署任务id。 取值范围： 由英文字母、数字组成，且长度为32个字符。 请求示例 https

查看更多 →

推荐配套产品 在RR选择共部署的组网中，一般总部站点的CPE既是站点的网关，又要承担RR的职责，所以需要高性能的CPE设备。分支站点根据站点业务规模选择CPE。 本场景推荐的设备款型如表1所示。 表1 推荐款型 站点 设备款型 总部Hub站点/数据中心站点 AR6300（只支持单主控，不支持双主控）、AR6280。

查看更多 →

配置对接Kafka可靠性 配置场景 Spark Streaming对接Kafka时，当Spark Streaming应用重启后，应用根据上一次读取的topic offset作为起始位置和当前topic最新的offset作为结束位置从Kafka上读取数据的。 Kafka服务的top

查看更多 →

配置Flink对接Kafka安全认证 Flink样例工程的数据存储在Kafka组件中。向Kafka组件发送数据（需要有Kafka权限用户），并从Kafka组件接收数据。 确保集群安装完成，包括HDFS、Yarn、Flink和Kafka。 创建Topic。 用户使用Linux命令行

查看更多 →

配置Flink对接Kafka安全认证 Flink样例工程的数据存储在Kafka组件中。向Kafka组件发送数据（需要有Kafka权限用户），并从Kafka组件接收数据。 确保集群安装完成，包括HDFS、Yarn、Flink和Kafka。 创建Topic。 用户使用Linux命令行

查看更多 →

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

查看更多 →