Kafka to ElasticSearch

Elastic Stack Elasticsearch
5

Hi Mac,

I am using org.apache.flume.sink.elasticsearch.ElasticSearchDynamicSerializer in flume config and now kafka topic data coming in body. please share details if you fixed this issue

flume1.sinks.k1.serializer = org.apache.flume.sink.elasticsearch.ElasticSearchDynamicSerializer

{
_index: foo_index-2015-05-25
_type: bar_type
_id: AU2L8-LiEl9820ruvxyR
_version: 1
_score: 1
_source: {
body: {customer: customer1,network: network1, domain: XXX, kpiGroup:kpiGroup1 ,vendor: vendor1,entityType: entityType1}
timestamp: 1432572122700
topic: topic_name
}
}