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

Posted to user@flume.apache.org by أنس الليثي <de...@gmail.com> on 2015/10/25 12:37:00 UTC

How to override the Elasticsearch sink client?

I are using Flume for ingesting data into Elasticsearch and I need to
change the default behavior of the TransportClient used by flume.

The behavior I need to override is in the addEvent class
of org.apache.flume.sink.elasticsearch.client.ElasticSearchTransportClient.

If I wrote the required changes, how can I change the configuration to make
the sink use the new class not the old one?

regards