I am trying to use flume to send data to elastic . Flume collects the logs from kafka and sinks it to elastic. log format in kafka is in avro. Data that goes to elastic has to be in json format. can anyone suggest me an existing interceptor/serializer to convert avro to elastic suitable format .