当前位置:网站首页>Specify flume introduction, installation and configuration
Specify flume introduction, installation and configuration
2022-07-06 18:30:00 【Full stack programmer webmaster】
Hello everyone , I meet you again , I'm the king of the whole stack .
editorial :
This paper summarizes “Hadoop The ecological system ” One of them ——Apache Flume
Write in the first two :
Description of the software used :
One 、 What is? Apache Flume
Official website :Flume is a distributed, reliable, and availableservicefor efficientlycollecting, aggregating, and moving large amounts of log data. It has a simple and flexible architecture based on streaming data flows. It is robust and fault tolerant with tunable reliability mechanisms and many failover and recovery mechanisms. It uses a simple extensible data model that allows for online analytic application.
1、flume It is a distributed log collection system , With high reliability 、 High availability 、 Business management 、 Failed restart and other functions . Data processing speed is fast , It can be completely used in the production environment . Frequently used distributed log collection system : Apache Flume、 Facebook Scribe、 Apache Chukwa 2、flume The core is agent.
agent It's a java process , Execute on the log collection side , adopt agent Receiving log . Then store it temporarily , And send it to the destination . 3、agent includes 3 Core components :source、channel、sink.
3.1、source The component is dedicated to collecting logs . It can handle various types and formats of log data , contain avro、thrift、exec、jms、spooling directory、netcat、 sequence generator、syslog、http、legacy、 Define your own .source After the component collects the data . Temporarily stored in channel in .
3.2、channel The component is in the agent Designed for temporary storage of data , Can be stored in memory、jdbc、file、 Define your own . channel The data in is only in sink It will not be deleted until it is successfully sent . 3.3、sink A component is a component used to send data to a destination , The destination contains hdfs、logger、avro、thrift、ipc、file、null、hbase、solr、 Define your own . 4、 In the whole process of data transmission . What's flowing is event. The transaction guarantee is in event Level . 5、flume It can support multiple levels flume Of agent, Support fan in (fan-in)、 Fan out (fan-out).
Flume Simple processing diagram
Flume Schematic diagram of complex processing
Two 、Flume Installation configuration
2.1、 download Flume
2.2、 decompression
cd /home/yujianxin/flume tar -zxvf apache-flume-1.4.0-src.tar.gz ; tar -zxvfapache-flume-1.4.0-bin.tar.gz
And then put src All contents in the directory are copied to bin Catalog
2.3、 To configure Flume environment variable
3、 ... and 、 verification Flume Is the installation successful
OK!
The screenshot above appears , explain Flume Installation successful .
Copyright notice : This article is an original blog article , Blog , Without consent , Shall not be reproduced .
Publisher : Full stack programmer stack length , Reprint please indicate the source :https://javaforall.cn/117390.html Link to the original text :https://javaforall.cn
边栏推荐
- STM32+ENC28J60+UIP协议栈实现WEB服务器示例
- C language exchanges two numbers through pointers
- Excel usage record
- Prophet模型的简介以及案例分析
- Shangsilicon Valley JUC high concurrency programming learning notes (3) multi thread lock
- 2022暑期项目实训(二)
- Recommend easy-to-use backstage management scaffolding, everyone open source
- Interesting - questions about undefined
- 使用block实现两个页面之间的传统价值观
- Introduction to the usage of model view delegate principal-agent mechanism in QT
猜你喜欢
Comparative examples of C language pointers *p++, * (p++), * ++p, * (++p), (*p) + +, +(*p)
Penetration test information collection - CDN bypass
[.Net core] solution to error reporting due to too long request length
【LeetCode第 300 场周赛】
Ms-tct: INRIA & SBU proposed a multi-scale time transformer for motion detection. The effect is SOTA! Open source! (CVPR2022)...
UDP协议:因性善而简单,难免碰到“城会玩”
微信为什么使用 SQLite 保存聊天记录?
MS-TCT:Inria&SBU提出用于动作检测的多尺度时间Transformer,效果SOTA!已开源!(CVPR2022)...
Splay
關於這次通信故障,我想多說幾句…
随机推荐
Picture zoom Center
Codeforces Round #803 (Div. 2)
SQL优化问题的简述
Implementation of queue
[.Net core] solution to error reporting due to too long request length
UDP protocol: simple because of good nature, it is inevitable to encounter "city can play"
传输层 拥塞控制-慢开始和拥塞避免 快重传 快恢复
CSRF漏洞分析
MySQL查询请求的执行过程——底层原理
Reprint: defect detection technology of industrial components based on deep learning
使用block实现两个页面之间的传统价值观
STM32+HC05串口蓝牙设计简易的蓝牙音箱
首先看K一个难看的数字
随着MapReduce job实现去加重,多种输出文件夹
Grafana 9.0 is officially released! It's the strongest!
FMT open source self driving instrument | FMT middleware: a high real-time distributed log module Mlog
第三季百度网盘AI大赛盛夏来袭,寻找热爱AI的你!
Interview shock 62: what are the precautions for group by?
徐翔妻子应莹回应“股评”:自己写的!
declval(指导函数返回值范例)