Event Serializers Body Text Serializer “Flume Event” Avro Event Serializer Avro Event Serializer Event Serializers The file_roll sink and the hdfs sink both support theEvent...

Monitoring Available Component Metrics Sources 1 Sources 2 Sinks 1 Sinks 2 Channels JMX Reporting Ganglia Reporting JSON Reporting Custom Reporting Reporting metrics from...

监控 JMX Reporting Ganglia Reporting JSON Reporting Custom Reporting Reporting metrics from custom components 监控 Flume的监控系统的完善仍在进行中，变化可能会比较频繁，有几个Flume组件会向JMX平台MBean服务器报告运行指标...

Event序列化器 消息体文本序列化器 Flume Event的Avro序列化器 Avro序列化器 Event序列化器 File Roll Sink 和 HDFS Sink 都使用过 EventSerializer 接口。下面介绍了随Flume一起提供的Event序列化器的详细信息。 消息体文本序列化器 它的别名是：text。这个序列...

Troubleshooting Handling agent failures Compatibility HDFS AVRO Additional version requirements Tracing More Sample Configs Troubleshooting Handling agent failures If ...

什么是RPC？ 安全的RPC 客户端 —— Thrift 容错机制 负载均衡 嵌入式节点 什么是RPC？ RPC（Remote Procedure Call Protocol）——远程过程调用协议 安全的RPC 客户端 —— Thrift 在1.6版本中，Thrift的source和sink支持kerberos认证。客户端需要使用sec...

Architecture Data flow model Reliability Architecture Data flow model An Event is a unit of data that flows through a Flume agent. The Event flows from Source to Channel ...

Overview Overview Apache Flume is a distributed, reliable, and available system forefficiently collecting, aggregating and moving large amounts of logdata from many different s...

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

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