一、Memory Channel

事件将被存储在内存中(指定大小的队列里)

非常适合那些需要高吞吐量且允许数据丢失的场景下

属性说明:

二、JDBC Channel

事件会被持久化(存储)到可靠的数据库里,目前支持嵌入式Derby数据库。即source=》channel=》sink。在传输的过程中,会先把事件存到关系型数据库里。但是Derby数据库不太好用,所以JDBC Channel目前仅用于测试,不能用于生产环境。

三、FileChannel

好处:数据不丢失

坏处:极大的降低flume的吞吐量,因为要频繁的发生磁盘I/O

性能比较低,但是即使程序出错数据不会丢失

性能会比较低下,但是即使程序出错数据不会丢失

配置实例:

a1.sources=r1
a1.channels=c1
a1.sinks=s1a1.sources.r1.type=netcat
a1.sources.r1.bind=0.0.0.0
a1.sources.r1.port=8888a1.sinks.s1.type=loggera1.channels.c1.type=file
a1.channels.c1.dataDirs=/home/filechannela1.sources.r1.channels=c1
a1.sinks.s1.channel=c1

四、内存溢出通道

优先把Event存到内存中,如果存不下,在溢出到文件中,目前处于测试阶段,还未能用于生产环境

转载于:https://www.cnblogs.com/chuijingjing/p/10149774.html

Flume的Channel相关推荐

  1. flume ChannelSelector -- channel 选择器

    首先是flume中三个组件的单词的意思,flume:水道:笕槽:引水槽,source:水源,channel:水渠,sink:水槽.见文知意,就是水从源头流出来,经过水渠或者管道,最终流到终点,也就是水 ...

  2. 大数据——Flume组件Source、Channel和Sink具体使用

    Flume组件Source.Channel和Sink使用说明 Flume Sources Avro Source 配置范例 Thrift Source 配置范例 Exec Source 配置范例 JM ...

  3. flume 1.7在windows下的安装与运行

    flume 1.7在windows下的安装与运行 一.安装 安装java,配置环境变量. 安装flume,flume的官网http://flume.apache.org/,下载地址,下载后直接解压即可 ...

  4. 【原创】flume-1.3.0安装配置以及flume启动说明

    Flume介绍 一 flume基本介绍 Apache flume是一个分布式的.可靠的和可用的用来高效收集.同济和移动大量数据从众多不同sources到一个集中的数据存储库的系统. Flume eve ...

  5. 大剑无锋之flume面试题【面试推荐】

    1 你是如何实现Flume数据传输的监控的 使用第三方框架Ganglia实时监控Flume. 2 Flume的Source,Sink,Channel的作用?你们Source是什么类型? 1.作用 (1 ...

  6. Flume原理及使用案例

    本文为转载篇!原文: https://www.cnblogs.com/zhangyinhua/p/7803486.html https://www.cnblogs.com/ciade/p/549521 ...

  7. Flume 实战开发指南

    Flume 文章目录 Flume Flume介绍 Flume核心概念 Flume NG的体系结构 Source Channel Sink Flume的部署类型 单一流程 多代理流程(多个agent顺序 ...

  8. CentOS7环境下搭建flume

    一.flume安装与配置 1.将flume解压到指定目录/home/jason/bigdata下: [root@clsserv202 bigdata]# pwd /home/jason/bigdata ...

  9. Apache Flume 简介

    转自:http://blog.163.com/guaiguai_family/blog/static/20078414520138100562883/ Flume 是 Cloudera 公司开源出来的 ...

最新文章

  1. 【组队学习】十二月微信图文索引
  2. 【译】.NET Core 是 .NET 的未来
  3. mysql迅速搭建网页_Django + mysql 快速搭建简单web投票系统
  4. 利用动态规划求连续数组最大和以及最大子矩阵的和
  5. [BizTalk]在高可用性环境下配置BizTalk的一些常见问题
  6. java代理通俗简单解析
  7. 迷惑!博士生发Nature造假,怕被调查扔掉实验室万元电脑
  8. 分布式系统一致性测试框架Jepsen在女娲的实践应用
  9. 支持XML的公司和它们的开发工具有哪些?
  10. 以太坊2.0合约余额新增2.62万ETH
  11. Python_字符串
  12. 如何使用以太网将 Mac 接入互联网?
  13. PHP中的++和--
  14. 《金字塔原理》读书笔记
  15. 利用envi进行监督分类(支持向量机)
  16. 美年旅游_自由行_自由行分页PageHelper
  17. 【软考系统架构设计师】2014年下系统架构师案例分析历年真题
  18. 软路由连接NAS做链路聚合
  19. NT151应用案例:西门子PLC S7-1200与派克ACR9000的通信(Part 4)
  20. SQL Server 2008 清理数据库日志文件

热门文章

  1. linux下配置myBase7.ini
  2. go日期和时间相关函数使用示例
  3. 阿里云ubuntu软件包镜像源地址
  4. Go gin获取post请求数据
  5. Spark弹性式数据集RDDs
  6. k8s kubesphere进入ks-installer容器删除istio并重启ks-installer命令
  7. python安装psutil库及使用
  8. Scala import导包用法
  9. SpringData Jpa、Hibernate、Jpa 三者之间的关系
  10. Queue接口中add()与offer(),remove()与poll(),element()与peek()方法区别