退出选项不够充分这种情况是很重要的,在这种情况下,如何创建一种自定义的机制发送数据。有两种方式:

    • 第一种就是创建自定义的客户端与flume的source进行交互,比如AvroSource和SyslogTcpSource。这样client需要把数据转换成flume理解的格式。

    注意,所有的数据都是存储在flume节点的channel中。

    RPC参考2:深入

    Avro是默认的RPC协议,NettyAvroRpcClient以及ThriftRpcClient都实现了RpcClient接口。客户端需要创建目标Agent的主机名以及端口号,并且使用RpcClient发送数据。下面就是一个数据产生的应用:

    远程的Flume节点需要有一个AvroSource的source,来监听某个端口。下面就是配置的例子: