How to override the Elasticsearch sink client?

14 views

Skip to first unread message

unread,

Oct 25, 2015, 7:42:43 AM10/25/15

to flume-user

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?