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 <> 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 ?