You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flume.apache.org by Johny Rufus <jr...@cloudera.com> on 2015/06/29 23:19:02 UTC

Re: Embedded flume agent.

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.

Thanks,
Rufus

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

> Hi,
>
> 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.
>
>
> Thanks,
>
> Satyendra
>