Kafka数据到Hdfs

news/2024/5/20 0:49:41 标签: Kafka, HDFS, Kafka同步数据到HDFS

找时间总结整理了下数据从Kafka到Hdfs的一些pipeline,如下

1> Kafka -> Flume –> Hadoop Hdfs

常用方案,基于配置,需要注意hdfs小文件性能等问题.

GitHub地址:  https://github.com/apache/flume

2> Kafka -> Kafka Hadoop Loader ->Hadoop Hdfs

Kafka Hadoop Loader通过为kafka Topic下每个分区建立对应的split来创建task实现增量的加载数据流到hdfs,上次消费的partition offset是通过zookeeper来记录的.简单易用.

GitHub地址:  https://github.com/michal-harish/kafka-hadoop-loader

3> Kafka -> KaBoom -> Hadoop Hdfs

KaBoom是一个借助Krackle(开源的kafka客户端,能极大的减少对象的创建,提高应用程序的性能)来消费kafka的Topic分区数据随后写如hdfs,利用Curator和Zookeeper来实现分布式服务,能够灵活的根据topic来写入不同的hdfs目录.

GitHub地址:  https://github.com/blackberry/KaBoom

4> Kafka -> Kafka-connect-hdfs -> Hadoop Hdfs

Confluent的Kafka Connect旨在通过标准化如何将数据移入和移出Kafka来简化构建大规模实时数据管道的过程。可以使用Kafka Connect读取或写入外部系统,管理数据流并扩展系统,而无需编写新代码.

GitHub地址:  https://github.com/confluentinc/kafka-connect-hdfs

5> Kafka -> Gobblin -> Hadoop Hdfs

Gobblin是LinkedIn开源的一个数据摄取组件.它支持多种数据源的摄取,通过并发的多任务进行数据抽取,转换,清洗,最终加载到目标数据源.支持单机和Hadoop MR二种方式,而且开箱即用,并支持很好的扩展和二次开发.

GitHub地址:  https://github.com/linkedin/gobblin


http://www.niftyadmin.cn/n/1638833.html

相关文章

揭秘阿里百亿级云客服实时分析架构演进之路

淘宝、天猫每天有上亿个不同的买卖家进行对话,产生百亿条聊天记录。对客服聊天记录的实时分析是实现智能客服的基础。本文主要分享云客服的整体架构,包括实时分析的场景、架构、技术难点,以及为何要从 NoSQL 迁移时序数据库和使用心得。 网…

Java 程序员常用资源工具集合(建议收藏)

搜索资源网站 学习技术过程我们经常需要使用搜索引擎来检索资料,国内常用的也就是某度了。 当然有条件的话,搜索引擎首先还是推荐使用 Google,如果没办法使用,可以使用以下几个作为备用: Bing Bing 国际版&#xf…

RunTime.getRunTime().addShutdownHook优雅关闭线程池

有时候我们用到的程序不一定总是在JVM里面驻守,可能调用完就不用了,释放资源. RunTime.getRunTime().addShutdownHook的作用就是在JVM销毁前执行的一个线程.当然这个线程依然要自己写. 利用这个性质,如果我们之前定义了一系列的线程池供程序本身使用,那么就可以在这个最后执行…

Java8 map合并新姿势

1. 介绍 本入门教程将介绍Java8中如何合并两个map。 更具体说来&#xff0c;我们将研究不同的合并方案&#xff0c;包括Map含有重复元素的情况。 2. 初始化 我们定义两个map实例 private static Map<String, Employee> map1 new HashMap<>(); private static…

EnumSet基本用法

EnumSet基本用法 enum Season {SPRING, SUMMER, FALL, WINTER }public class EnumSetTest {public static void main(String[] args) {//创建一个EnumSet集合&#xff0c;集合元素就是Season枚举类的全部枚举值EnumSet es1 EnumSet.allOf(Season.class);//输出[SPRING, SUMMER…

log4j2日志配置说明

在项目推进中&#xff0c;如果说第一件事是搭Spring框架的话&#xff0c;那么第二件事情就是在Sring基础上搭建日志框架&#xff0c;我想很多人都知道日志对于一个项目的重要性&#xff0c;尤其是线上Web项目&#xff0c;因为日志可能是我们了解应用如何执行的唯一方式。在18年…

java自定义线程池详细使用说明

前言 线程池想必大家也都用过&#xff0c;JDK的Executors 也自带一些线程池。但是不知道大家有没有想过&#xff0c;如何才是最优雅的方式去使用过线程池吗&#xff1f; 生产环境要怎么去配置自己的线程池才是合理的呢&#xff1f; 今天周末&#xff0c;刚好有时间来总结一下自…

SpringBoot整合log4j2详细教程

首先&#xff0c;认识一下三胞胎 log4j是apache实现的一个开源日志组件logback同样是由log4j的作者设计完成的&#xff0c;拥有更好的特性&#xff0c;用来取代log4j的一个日志框架&#xff0c;是slf4j的原生实现Log4j2是log4j 1.x和logback的改进版&#xff0c;据说采用了一些…