`
jamie.wang
  • 浏览: 348816 次
  • 性别: Icon_minigender_1
  • 来自: 成都
社区版块
存档分类
最新评论

flume-ng安装

阅读更多

 

下载flume-ng

$ wget http://mirrors.hust.edu.cn/apache/flume/1.5.2/apache-flume-1.5.2-bin.tar.gz

解压,创建文件输出目录

创建flume的配置

$ vi conf/flume-conf.properties

 

agent1.sources = source1
agent1.sinks = sink1
agent1.channels = channel1
 
# Describe/configure source1
agent1.sources.source1.type = avro
agent1.sources.source1.bind = 10.111.131.68 # avro监听host
agent1.sources.source1.port = 44446 # avro监听port
agent1.sources.source1.channels = channel1
 
# Use a channel which buffers events in memory
agent1.channels.channel1.type = memory
agent1.channels.channel1.capacity = 1000
agent1.channels.channel1.transactionCapactiy = 100 
 
# Bind the source and sink to the channel
# Describe sink1
agent1.sinks.sink1.type = file_roll # 文件输出
agent1.sinks.sink1.sink.directory = /home/hai/app-monitoring/flume/apache-flume-1.5.2-bin/flumed-logs # 文件输出目录
agent1.sinks.sink1.channel = channel1

 

拷贝

apache-flume-1.5.2-bin/tools/flume-ng-log4jappender-1.5.2-jar-with-dependencies.jar

到需要输出日志的应用的WEB-INF/lib下

修改log4j配置

log4j.appender.flume=org.apache.flume.clients.log4jappender.Log4jAppender
log4j.appender.flume.layout=org.apache.log4j.PatternLayout
log4j.appender.flume.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss}%5p %F %L %m%n
log4j.appender.flume.Hostname=10.111.131.68
log4j.appender.flume.Port=44446
log4j.rootCategory=DEBUG, console, flume

启动flume

bin/flume-ng agent -n agent1 -c conf -f conf/flume-conf.properties -Dflume.monitoring.type=http -Dflume.monitoring.port=34545

接下来就可以在日志输出目录查看到日志文件了

这个页面可以看到flume的计量信息

http://10.111.131.68:34545/metrics

$ ls flumed-logs/
1426141638517-1   1426141638517-14  1426141638517-19  1426141638517-23  1426141638517-28  1426141638517-32  1426141638517-37  1426141638517-7
1426141638517-10  1426141638517-15  1426141638517-2   1426141638517-24  1426141638517-29  1426141638517-33  1426141638517-38  1426141638517-8
1426141638517-11  1426141638517-16  1426141638517-20  1426141638517-25  1426141638517-3   1426141638517-34  1426141638517-4   1426141638517-9
分享到:
评论

相关推荐

    flume-ng-sql-source-release-1.5.2.zip

    Flume-ng-sql-source是Apache Flume的一个扩展插件,主要功能是允许用户从各种数据库中抽取数据并将其传输到其他目的地,如Apache Kafka。在本案例中,我们讨论的是版本1.5.2的发布包,即"flume-ng-sql-source-...

    Flume-ng在windows环境搭建并测试+log4j日志通过Flume输出到HDFS.docx

    <groupId>org.apache.flume.flume-ng-clients <artifactId>flume-ng-log4jappender <version>1.6.0 ``` 配置 log4j.properties 文件,如下: ``` ### set log levels ### log4j.rootLogger=INFO, stdout, file...

    flume-ng-sql-source-1.5.2

    - **数据库兼容性**:Flume-ng-sql-source通常需要JDBC驱动来连接各种类型的SQL数据库,因此需要确保正确安装并配置了相应的驱动。 - **查询定制**:用户可以编写自定义SQL查询来获取所需的数据,也可以根据时间戳...

    Flume-ng-1.6.0-cdh.zip

    Flume-ng-1.6.0-cdh.zip 内压缩了 3 个项目,分别为:flume-ng-1.6.0-cdh5.5.0.tar.gz、flume-ng-1.6.0-cdh5.7.0.tar.gz 和 flume-ng-1.6.0-cdh5.10.1.tar.gz,选择你需要的版本。

    flume-ng-sql-source

    包含flume-ng-sql-source-1.5.1&flume;-ng-sql-source-1.4.1 此内容均为网上下载

    flume-ng-sql-source-1.4.3.jar

    1. **安装与依赖**:首先需要将flume-ng-sql-source-1.4.3.jar添加到Flume的类路径中,确保所有必要的JDBC驱动也在类路径内,因为这些驱动是连接数据库所必需的。 2. **配置源**:在Flume的配置文件(如flume.conf...

    flume-ng-sql-source-1.5.1

    flume-ng-sql-source-1.5.1 flume连接数据库 很好用的工具

    flume-ng-sql-source-1.5.3.jar

    flume-ng-sql-source-1.5.3.jar,flume采集mysql数据jar包,将此文件拖入FLUME_HOME/lib目录下,如果是CM下CDH版本的flume,则放到/opt/cloudera/parcels/CDH-xxxx/lib/flume-ng/lib下,同样需要的包还有mysql-...

    flume-ng-1.6.0-cdh5.5.0.tar.gz

    "flume-ng-1.6.0-cdh5.5.0.tar.gz" 是 Apache Flume 的一个特定版本,具体来说是 "Next Generation" (ng) 版本的 1.6.0,与 Cloudera Data Hub (CDH) 5.5.0 发行版兼容。CDH 是一个包含多个开源大数据组件的商业发行...

    flume-ng-sql-source-1.4.1

    flume-ng-sql-source-1.4.1 flume采集mysql数据到kudu

    flume-ng-sql-source-1.5.2.jar

    flume-ng-sql-source-1.5.2.jar从数据库中增量读取数据到hdfs中的jar包

    flume-ng-1.6.0 cdh5.7.0安装包

    在安装和配置Flume-ng-1.6.0-cdh5.7.0时,用户需要注意以下几点: 1. 确保系统环境满足CDH 5.7.0的硬件和软件要求。 2. 安装Java开发环境,因为Flume依赖Java运行。 3. 解压压缩包`apache-flume-1.6.0-cdh5.7.0-bin`...

    flume-ng-sql-source.jar

    flume是一个日志收集器,更多详细的介绍可以参照官网:http://flume.apache.org/ flume-ng-sql-source实现oracle增量数据读取 有了这个jar文件即可从关系型数据库拉去数据到flume

    flume-ng-1.6.0-cdh5.10.1.tar.gz的下载

    `flume-ng-1.6.0-cdh5.10.1.tar.gz` 是一个针对Cloudera Distribution Including Apache Hadoop (CDH) 5.10.1 版本优化的Flume NG的打包文件,Flume NG是Flume的下一代版本,提供更先进的特性和性能。 Flume的核心...

    flume-ng-1.5.0-cdh5.3.6.tar.gz

    `flume-ng-1.5.0-cdh5.3.6.tar.gz`解压后得到的`apache-flume-1.5.0-cdh5.3.6-bin`目录包含了Flume的二进制文件和配置文件。在实际应用中,我们需要创建自定义的Flume配置文件(通常为`flume.conf`),定义Source、...

    flume-ng-1.5.0-cdh5.3.6.rar

    flume-ng-1.5.0-cdh5.3.6.rarflume-ng-1.5.0-cdh5.3.6.rar flume-ng-1.5.0-cdh5.3.6.rar flume-ng-1.5.0-cdh5.3.6.rar flume-ng-1.5.0-cdh5.3.6.rar flume-ng-1.5.0-cdh5.3.6.rar flume-ng-1.5.0-cdh5.3.6.rar flume...

    flume-ng-sdk-1.6.0.ja

    flume-ng-sdk-1.6.0.ja,如果想要通过log4j将日志直接导入到flume需要导入这个jar包

Global site tag (gtag.js) - Google Analytics