Embedded Agent is designed to send events to other Flume agents (as opposed to sending events to the final destination), and hence only Avro RPC Sink is supported. 

If you want to support other sinks, you should look at changing the value ALLOWED_SINKS in EmbeddedAgentConfiguration and take things from there.


On Mon, Jun 29, 2015 at 4:21 AM, Satyendra Kumar Bilthare (Vizury) <satyendra.kumar@vizury.com> wrote:

I want to use embedded flume agent to write to kafkasink.
Currently only avro sink is supported in embedded flume sink.

Why other sinks are not supported?
What modifications will i need in order to write kafkasink.