Apache Flume User Guide

• Flume 1.9.0 用户指南
  • Introduction
    • Overview
    • System Requirements
    • Architecture
      • 数据流模型
      • Complex flows
      • Reliability
      • Recoverability
  • Setup
    • 设置代理
      • 配置单个组件
      • 将 Component 连接在一起
      • 开始代理
      • 一个简单的例子
      • 在配置文件中使用环境变量
      • 记录原始数据
      • 基于 Zookeeper 的配置
      • 安装第三方插件
        • plugins.d 目录
        • 插件的目录布局
    • Data ingestion
      • RPC
      • Executing commands
      • Network streams
    • 设置多主体流程
    • Consolidation
    • 多路流
  • Configuration
    • 定义流程
    • 配置单个组件
    • 在代理中添加多个流
    • 配置多代理流程
    • 扇出流量
    • SSL/TLS support
    • 源和汇批次大小和 ChannelTransaction 能力
    • Flume Sources
      • Avro Source
      • Thrift Source
      • Exec Source
      • JMS Source
        • JMS 消息转换器
        • SSL 和 JMS 来源
      • 假脱机目录源
        • Event Deserializers
          • LINE
          • AVRO
          • BlobDeserializer
      • Taildir Source
      • Twitter 1％的水喉源(实验)
      • Kafka Source
      • NetCat TCP 源
      • NetCat UDP 源
      • 序列发生器源
      • Syslog Sources
        • Syslog TCP 源
        • 多端口 Syslog TCP 源
        • Syslog UDP 源
      • HTTP Source
        • JSONHandler
        • BlobHandler
      • Stress Source
      • Legacy Sources
        • Avro 传统资源
        • 节俭 Legacy 来源
      • Custom Source
      • Scribe Source
    • Flume Sinks
      • HDFS Sink
      • Hive Sink
      • Logger Sink
      • Avro Sink
      • Thrift Sink
      • IRC Sink
      • 文件卷槽
      • Null Sink
      • HBaseSinks
        • HBaseSink
        • HBase2Sink
        • AsyncHBaseSink
      • MorphlineSolrSink
      • ElasticSearchSink
      • Kite 数据集接收器
      • Kafka Sink
      • HTTP Sink
      • Custom Sink
    • Flume Channels
      • Memory Channel
      • JDBC Channel
      • Kafka Channel
      • File Channel
      • 溢出内存通道
      • 伪 TransactionChannels
      • Custom Channel
    • Sink 通道 selectors
      • 复制通道 selectors(默认)
      • 多路通道 selectors
      • 自定义 Channelsselectors
    • SinkSink 处理器
      • 默认接收器处理器
      • 故障转移接收器处理器
      • 负载均衡接收器处理器
      • 定制 Sink 处理器
    • Event Serializers
      • 正文文本序列化器
      • “ Flume 事件” Avro 事件序列化器
      • Avro 事件序列化器
    • Flume Interceptors
      • Timestamp Interceptor
      • Host Interceptor
      • Static Interceptor
      • 删除页眉拦截器
      • UUID Interceptor
      • Morphline Interceptor
      • 搜索并替换拦截器
      • 正则表达式过滤拦截器
      • 正则表达式提取器拦截器
      • Example 1:
      • Example 2:
    • Flume Properties
      • Property: flume.called.from.service
  • Configuration Filters
    • 配置过滤器的常见用法
    • 环境变量配置过滤器
      • Example
    • 外部流程配置过滤器
      • Example
      • Example 2
    • Hadoop 凭证存储配置过滤器
      • Example
  • Log4J Appender
  • 负载平衡 Log4J Appender
  • Security
  • Monitoring
    • 可用组件 Metrics
      • Sources 1
      • Sources 2
      • Sinks 1
      • Sinks 2
      • Channels
    • JMX Reporting
    • Ganglia Reporting
    • JSON Reporting
    • Custom Reporting
    • 来自自定义组件的报告 Metrics
  • Tools
    • 文件通道完整性工具
    • 事件验证工具
  • 拓扑设计注意事项
    • Flume 非常适合您的问题吗？
    • Sink 中的流量可靠性
    • Sink 拓扑设计
    • 调整 Flume 部署的规模
  • Troubleshooting
    • 处理代理故障
    • Compatibility
      • HDFS
      • AVRO
      • 附加版本要求
    • Tracing
    • 更多 samples 配置
  • Component Summary
  • Alias Conventions