flume-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Johny Rufus <jru...@cloudera.com>
Subject Re: Usage of Flume in JAVA code
Date Tue, 16 Jun 2015 22:24:14 GMT
An embedded agent only supports Embedded source/Avro sink combination, as
it is mainly used to send data generated by an application to a next level
flume agent running Avro source.
For your case, you need to setup a Flume agent configured with an exec
source and roll file sink. (as the data is generated by a command which you
are executing and not by your java application )


On Tue, Jun 16, 2015 at 11:14 AM, Nithesh Kb <nitheshkb12@gmail.com> wrote:

> Hi Flume Masters,
> I'm new to flume please help me to get some idea on this query.
> I saw in Apache developers guide that
> '' Specifically the source used is a special embedded source and events
> should be send to the source via the put, putAll methods on the
> EmbeddedAgent object"
> suppose if i want to use exec as source and roll_file as sink, how do i
> configure this in JAVA code ?
> Thanks,
> Nithesh

View raw message