Nickolay Kolevbest regards,Now it is hosted on company's internal repo but if you have interest I can upload it on GitHub or BitbucketI am not java developer so probably it is not the best solution but it works.We have the same problem and I have developed patch and custom version based on sources (two months ago)Hi,It looks like ES sink is oriented to handle text payload and not json and there are problems with serialization.On Mon, Nov 17, 2014 at 11:47 AM, shadyxu <email@example.com> wrote:Hi everyone,I am now using Flume to collect log into ElasticSearch. And the logs are in json format. However, when I check them in ES, it seems that Flume has put the entire json log in the @message attribute. Is there any config to do or need I do some coding to separate them into different columns as ES always does?BTW, I found that ttl seems not working in ElasticSearch. I'm using Flume 188.8.131.52.Any clue shall be appreciated.