故障排除 处理Agent失败 兼容性 HDFS AVRO Additional version requirements Tracing More Sample Configs 故障排除 处理Agent失败 如果Flume的Agent挂掉，则该Agent上托管的所有流都将中止。 重新启动Agent后，这些流将恢复。 使用文件chan...

架构 数据流模型 可靠性 架构 数据流模型 在Flume节点中是以Event为数据单元，Event从source 经过channel 交给sink 。Event对象携带了payload信息（由一系列的数据以及headers组成，可以理解成一个hash表）。Flume节点是一个JVM的进程，并由一系列的节点组成，使event对象可以从外部的数据...

Configuration Filters Common usage of config filters Environment Variable Config Filter Example External Process Config Filter Example Example 2 Hadoop Credential Store Confi...

社会媒体分析 社会媒体分析条件 设置 AWS 环境 建立一个 Twitter 和 Flume 的证书 预先在 AWS 上设置一个 MapR 节点 更新 Flume 配置文件 提供一个 MicroStrategy AWS 实例 配置 MicroStrategy 导入报表 更新 Schema 创建用户并设置密码 关于报告 使用 Web 接口...

Tools File Channel Integrity Tool Event Validator Tool Tools File Channel Integrity Tool File Channel Integrity tool verifies the integrity of individual Events in the File...

Built-in connector Source connector Canal Debezium MySQL Debezium PostgreSQL Debezium MongoDB Debezium Oracle Debezium Microsoft SQL Server DynamoDB File Flume Twitter fir...

SSL/TLS support SSL/TLS support Several Flume components support the SSL/TLS protocols in order to communicate with other systemssecurely. Component SSL server or client Avro ...

Source connector Canal Debezium MySQL Debezium PostgreSQL Debezium MongoDB DynamoDB File Flume Twitter firehose Kafka Kinesis Netty RabbitMQ Sink connector Aerospike ...

Built-in connector Source connector Canal Debezium MySQL Debezium PostgreSQL Debezium MongoDB Debezium Oracle Debezium Microsoft SQL Server DynamoDB File Flume Twitter fir...

Built-in connector Source connector Canal Debezium MySQL Debezium PostgreSQL Debezium MongoDB DynamoDB File Flume Twitter firehose Kafka Kinesis Netty NSQ RabbitMQ Si...