使用SpringBoot生产消费Kafka集群数据 本章节适用于 MRS 3.3.0及之后版本。 功能简介 通过SpringBoot实现对Kafka集群生产消费的功能。 代码样例 通过SpringBoot实现Kafka生产消费的样例代码如下： @RestController public

查看更多 →

创建的Kafka实例是集群模式么？ Kafka实例分为单机版实例和集群实例，单机版实例只有一个代理，是单机模式。集群实例由3个及以上代理组成，是集群模式。 父主题： 实例问题

查看更多 →

容量配置 管理线缆颜色和类型 管理标签 设置容量阈值 设置容量开关 父主题： 容量管理

查看更多 →

容量报告 操作步骤 登录管理控制台。 选择“服务列表 > 管理与监管 > 优化顾问”优化顾问服务页面。 按照前文步骤进行日常风险预测或重保风险预测。 左侧导航树选择“容量优化 > 容量报告”。 点击报告右侧“下载”，点击“是”进行容量报告下载，您也可以在日常风险预测和重保风险预测页面内进行报告导出。

查看更多 →

容量预估 数据库实例在使用过程中，当前磁盘空间数据与日志的占比以及历史上涨情况往往是用户关心的重点。数据管理服务提供了容量预估功能，可以方便地查看磁盘空间概况与分布，并通过历史数据结合智能算法提供了空间预估等功能，尽早发现空间不足的情况并及时避免。此外还提供了智能扩容、表智能诊断、TOP50库表等高级智能运维功能。

查看更多 →

查看容量排名 提供用户查看已关联的资源容量排名的能力。 操作场景 通过Cloud Operations Center查看已关联的资源容量排名。 操作步骤 登录COC。 在左侧菜单栏选择“资源管理 > 应用资源管理”，进入“应用资源管理”页面，选择“应用管理”页签，单击“容量”。 图1

查看更多 →

${BIGDATA_DATA_HOME}/kafka/data1/kafka-logs,${BIGDATA_DATA_HOME}/kafka/data2/kafka-logs”。 单击“保存”，并单击“确定”。界面提示“操作成功”，单击“完成”。 选择“集群 > 服务 > Kafka ，右上角选择“更多

查看更多 →

${BIGDATA_DATA_HOME}/kafka/data1/kafka-logs,${BIGDATA_DATA_HOME}/kafka/data2/kafka-logs”。 单击“保存”，并单击“确定”。界面提示“操作成功”，单击“完成”。 选择“集群 > 服务 > Kafka”，右上角选择“更多

查看更多 →

步骤一：创建分布式消息kafka 登录华为云控制台 单击“服务列表”，选择“应用中间件 > 分布式消息服务kafka版”，进入“分布式消息服务kafka版”页面，如下图所： 图2 分布式消息服务kafka版 单击“购买Kafka实例”，本次实验配置如下： 图3 购买Kafka实例 步骤二：开启SmartConnect

查看更多 →

如何选择Kafka实例的存储空间？ 存储空间主要是指用于存储消息（包括副本中的消息）、日志和元数据所需要的空间。选择存储空间时，需要选择磁盘类型和磁盘大小。更多磁盘信息，请参考如何选择磁盘类型。 假设业务存储数据保留天数内磁盘大小为100GB，则磁盘容量最少为100GB*副本数 +

查看更多 →

TRACE://:21013”，修改配置保存后重启Kafka集群。 如果当前集群为MRS 3.2.0-LTS.1，执行该步骤无法通过EIP访问Kafka时，可以参考如下操作进行处理： 登录到 FusionInsight Manager页面，选择“集群 > 服务 > Kafka > 实例”，勾选所有Broker实例，选择“更多

查看更多 →

登录到FusionInsight Manager页面，选择“集群 > 服务 > Kafka > 实例”，勾选所有Broker实例，单击“启动实例”。 给MRS服务集群的Broker节点分别绑定EIP。 在Windows通过已配置的Broker节点EIP地址和端口连接到Kafka集群并调试代码。 运行样例代码前，

查看更多 →

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

查看更多 →

kinit 组件业务用户 执行以下命令，切换到Kafka客户端安装目录。 cd Kafka/kafka 使用“kafka-balancer.sh”进行用户集群均衡，常用命令如下： 使用--run命令执行集群均衡： ./bin/kafka-balancer.sh --run --zookeeper

查看更多 →

如何选择Kafka实例的存储空间？ Kafka实例的超高IO和高IO如何选择？ 如何选择Kafka实例存储容量阈值策略？ Kafka服务端支持版本是多少？ Kafka实例的ZK地址是什么？ 创建的Kafka实例是集群模式么？ Kafka实例是否支持修改访问端口？ Kafka实例的SSL证书有效期多长？

查看更多 →

kinit 组件业务用户 执行以下命令，切换到Kafka客户端安装目录。 cd Kafka/kafka 使用“kafka-balancer.sh”进行用户集群均衡，常用命令如下： 使用--run命令执行集群均衡： ./bin/kafka-balancer.sh --run --zookeeper

查看更多 →

方式防止数据丢失。 分布式 分布式系统，易于向外扩展。每个集群支持部署多个Producer、Broker和Consumer，从而形成分布式的集群，无需停机即可扩展系统。 Kafka UI Kafka UI提供Kafka Web服务，通过界面展示Kafka集群中Broker、Top

查看更多 →

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开源增强特性 父主题： 组件介绍

查看更多 →

group_msgs 堆积消息数 该指标用于统计Kafka实例中所有消费组中总堆积消息数。 topic_messages_remained 队列可消费消息数 该指标用于统计消费组指定队列可以消费的消息个数。 broker_messages_in_rate 每秒消息生产速率 统计Kafka节点每秒生产速率。

查看更多 →