迁移。 前提条件 MRS 集群管理员已明确业务需求，并准备一个Kafka用户（属于kafkaadmin组，普通模式不需要）。 已安装Kafka客户端。 Kafka实例状态和磁盘状态均正常。 根据待迁移分区当前的磁盘空间占用情况，评估迁移后，不会导致新迁移后的磁盘空间不足。 使用Kafka客户端迁移数据

查看更多 →

日志 > 下载”。 在“服务”中勾选待操作集群的“ZooKeeper”。 单击右上角的设置日志收集的“开始时间”和“结束时间”分别为告警产生时间的前后10分钟，单击“下载”。 请联系运维人员，并发送已收集的故障日志信息。 告警清除 此告警修复后，系统会自动清除此告警，无需手工清除。 参考信息

查看更多 →

填写完成后单击“保存”，确认修改配置后单击“确定”。 单击“实例”，勾选所有FlinkServer实例，选择“更多 > 重启实例”，输入密码，单击“确定”重启实例。 使用具有FlinkServer管理员权限的用户登录 FusionInsight Manager。 选择“集群 > 服务

查看更多 →

Shell命令介绍 查看当前集群Topic列表。 shkafka-topics.sh --list --zookeeper <ZooKeeper集群IP:2181/kafka> shkafka-topics.sh --list --bootstrap-server <Kafka集群IP:21007>

查看更多 →

Shell命令介绍 查看当前集群Topic列表。 shkafka-topics.sh --list --zookeeper <ZooKeeper集群IP:2181/kafka> shkafka-topics.sh --list --bootstrap-server <Kafka集群IP:21007>

查看更多 →

告警”，根据告警帮助处理HDFS相关告警后，检查本告警是否恢复。 是，处理完毕。 否，执行5。 检查Yarn集群中的ResourceManager状态。 在FusionInsight Manager界面，选择“集群 > 待操作集群的名称 >服务 > Yarn”。 在“概览”中，检查Yarn集群中是否存在主ResourceManager实例。

查看更多 →

KrbServer服务不可用”的处理步骤处理故障后，检查本告警是否恢复。 是，处理完毕。 否，执行5。 检查Zookeeper服务状态。 在FusionInsight Manager的告警列表中，查看是否有“ALM-13000 ZooKeeper服务不可用”告警产生。 是，执行6。 否，执行7。

查看更多 →

--config cleanup.policy=compact Topic创建成功后，执行以下命令运行程序。 java -cp /opt/client/lib/*:/opt/client/src/main/resources com.huawei.bigdata.kafka.example

查看更多 →

操作步骤 登录FusionInsight Manager，具体请参见访问集群Manager。然后选择“集群 > 服务 > ZooKeeper > 实例”。 查看ZooKeeper角色实例的IP地址。 记录ZooKeeper角色实例其中任意一个的IP地址即可。 根据业务情况，准备好客户端，

查看更多 →

x及以前版本）的处理步骤处理故障后，检查本告警是否恢复。 是，处理完毕。 否，执行2.b。 检查HDFS服务状态。 登录MRS集群详情页面，选择“告警管理”。 在告警列表中，查看是否有HDFS相关告警产生。 是，执行2.c。 否，执行3.b。 单击“告警管理”，根据告警帮助处理HDFS相关告警后，检查本告警是否恢复。

查看更多 →

待访问集群的配置相同。 选择一个Windows系统的公共镜像。 其他配置参数详细信息，请参见“ 弹性云服务器 > 快速入门 > 购买并登录Windows弹性 云服务器 ” 方法二：使用本机访问MRS集群操作Hive。在安装开发环境后并完成以下步骤后再运行样例代码。 为MRS集群中要使用

查看更多 →

在FusionInsight Manager首页，选择“集群 > 待操作集群的名称 > 服务 > DBService”查看DBService的运行状态是否正常。 是，执行12。 否，执行11。 选择“更多 > 重启服务”重新启动DBService服务实例。重启完成后在告警列表中，查看“Loader服务不可用”告警是否清除。

查看更多 →

restart_app cep 重启后等待3分钟，再次查看kafka Topic监控。 在KafkaUI查看Kafka Topic信息 进入KafkaUI界面。 使用具有KafkaUI页面访问权限的用户登录FusionInsight Manager，选择“集群 > 服务 > Kafka”。

查看更多 →

policy=compact Topic创建成功后，执行以下命令运行程序。 java -cp /opt/client/lib/*:/opt/client/src/main/resources com.huawei.bigdata.kafka.example.WordCountDemo 重新打开

查看更多 →

policy=compact Topic创建成功后，执行以下命令运行程序。 java -cp /opt/client/lib/*:/opt/client/src/main/resources com.huawei.bigdata.kafka.example.WordCountDemo 重新打开

查看更多 →

x及后续版本。 前提条件 已安装集群客户端，例如安装目录为“/opt/client”。 各组件业务用户由MRS集群管理员根据业务需要创建。“机机”用户需要下载keytab文件，“人机”用户第一次登录时需修改密码。（普通模式不涉及） 在修改集群 域名 后，需要重新下载客户端，以保证客户端配置文件中kerberos

查看更多 →

MRS集群磁盘如何分区的？ MRS集群即发即用，不需用户自行规划磁盘分区。集群节点创建成功后，节点的操作系统磁盘分区说明如表1所示。 表1 MRS集群节点OS盘分区说明 分区类型 分区目录 容量 用途 OS分区 / 220GB 操作系统根分区目录和程序存放目录，包括了所有目录（除去下面指定的目录）。

查看更多 →

使用windows访问MRS集群来操作HBase，有如下两种方式： 申请一台windows的E CS 访问MRS集群操作hbase。安装开发环境后运行样例代码。申请ECS访问MRS集群的步骤如下： 在“现有集群”列表中，单击已创建的集群名称。 记录集群的“可用分区”、“虚拟私有云”、“集群控制台地址”

查看更多 →

云计算资源见《表2-2 资源和成本规划》 涉及软件： Mysql: 5.7 Redis: 6.2 Mongo: 4.4 Kafka: 2.5.12 Zookeeper: 3.6 Nginx: 1.24 Fastdfs: 6.06 Activemq: 5.17.6 Kkfileview: 4.1.0

查看更多 →

host1 :) kafka_skip_broken_messages （可选）表示忽略解析异常的Kafka数据的条数。如果出现了N条异常后，后台线程结束，Materialized View会被重新安排后台线程去监测数据。 kafka_num_consumers （可选）单个Kafka

查看更多 →

proxyuser.test.hosts”值为“*”：表示test用户连接后，可以使用任意代理用户，不限制集群节点。 参数“hadoop.proxyuser.test.groups”值为“*”：表示test用户连接后，可以使用任意代理用户，不限制代理用户所在的用户组。 修改如下参数值，

查看更多 →