问答 2023-07-13 来自:开发者社区

阿里云E-MapReduce clickhouse消费kafka的数据 kafka发生重启 ?

阿里云E-MapReduce clickhouse消费kafka的数据 kafka发生重启 clickhouse消费可能丢数据 有啥参数可以配置? 各位大神有遇到吗

问答 2022-12-13 来自:开发者社区

E-MapReduce中Kafka外网端口是多少

E-MapReduce中Kafka外网端口是多少

问答 2022-12-12 来自:开发者社区

E-MapReduce kafka分区使用不均衡如何处理

E-MapReduce kafka分区使用不均衡如何处理

文章 2019-03-20 来自:开发者社区

如何在E-MapReduce上进行Kafka集群间数据复制

1. 问题背景 我们在使用Kafka的时候,有时候会遇到以下几种场景: 原有Kafka集群机型配置过旧,需要升级换代,重新规划一个Kafka集群,将老集群的数据迁移到新集群上 数据上云,云下Kafka集群数据迁移到云上Kafka集群/Kafka服务 多个Kafka集群数据汇总到一个Kafka集群 基于业务Kafka集群,构建一个Kafka灾备集群 总结一下,以上场景可以抽象成两类: 数据迁...

文章 2018-08-09 来自:开发者社区

E-MapReduce上如何采集Kafka客户端Metrics

1. 背景 我们知道Kafka提供一套非常完善的Metrics数据,覆盖Broker,Consumer,Producer,Stream以及Connect。E-MapReduce通过Ganglia收集了Kafka Broker metrics信息,可以很好地监控Broker运行状态。但完整的Kafka应用包括Kafka Broker和Kafka 客户端这两个角色,当发生读写性能问题时,常常从Bro....

文章 2018-03-01 来自:开发者社区

E-MapReduce Kafka Benchmark - I

0. 测试目的 本文介绍如何利用Kafka自带的性能测试脚本测试E-MapReduce Kafka集群的性能,文末给出一份单机测试Kafka集群的性能数据。此数据仅供参考,不代表官方性能指标承诺。 非特定表述,以下所有Kafka集群指E-MapReduce Kafka集群。 1. 硬件配置 Kafka集群 节点 配置 机器数目 Master 非独享 4核16GB 80GB(高效云盘)x...

文章 2018-02-28 来自:开发者社区

E-MapReduce Kafka Kerberos集群授权

Kafka授权 如果没有开启Kafka认证(如Kerberos认证或者简单的用户名密码),即使开启了Kafka授权,用户也可以伪造身份访问服务。所以建议创建高安全模式(即支持Kerberos)的Kafka集群,详见Kerberos安全文档。 备注: 本文的权限配置只针对E-MapReduce的高安全模式集群,即Kafka以Kerberos的方式启动。 1. 添加配置 在Kafka集群的配置管理-....

文章 2018-02-09 来自:开发者社区

如何在E-MapReduce上提交Storm作业处理Kafka数据

0. 序言 本文演示如何在E-MapReduce上部署Storm集群和Kafka集群,并运行Storm作业消费Kafka数据。 1. 准备环境 这里我选择在杭州Region进行测试,版本选择EMR-3.8.0,本次测试需要的组件版本有: Kafka:2.11_1.0.0 Storm: 1.0.1 E-MapReduce的集群管理界面地址:https://emr.console.aliyun....

文章 2016-12-21 来自:开发者社区

如何在E-MapReduce上使用引导操作安装kafka组件

1. 什么是引导操作 关于E-MapReduce上引导操作的概念和使用方式请参考文档。 2. 编写安装Kafka组件的脚本 在E-MapReduce中编写安装Kafka组件脚本主要有以下几步: 下载Kafka-0.10.0.0安装包 修改Kafka配置文件 创建Kafka Log目录 启动Kafka daemon进程 以下是安装Kafka组件的脚本简单示例: #!/bin/bash isMa...

文章 2016-12-05 来自:开发者社区

使用E-MapReduce服务将Kafka数据导入OSS

概述 kafka是一个开源社区常用的消息队列,虽然kafka官方(Confluent公司)提供插件从Kafka直接导入数据到HDFS的connector,但对阿里云对文件存储系统OSS却没有官方的支持。本文会举一个简单的例子,实现kafka的数据写入阿里云OSS。因为阿里云E-MapReduce服务集成了大量开源组件和阿里云产品的对接工具,所以本文直接在E-MapReduce集群上运行这个例子。....

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

开源大数据平台 E-MapReduce

阿里云EMR是云原生开源大数据平台,为客户提供简单易集成的Hadoop、Hive、Spark、Flink、Presto、ClickHouse、StarRocks、Delta、Hudi等开源大数据计算和存储引擎,计算资源可以根据业务的需要调整。EMR可以部署在阿里云公有云的ECS和ACK平台。

+关注