Hello guys,

I trying to define a data flow to export data for MySQL to Elasticsearch. For 
this I’m using this processors

ExecuteSQL -> ConvertAvroToJSON -> PutElasticsearch 

But I’m getting errors with the last one. So what is the identifier Attribute 
of the PutElasticsearch processor for? I just want to insert the data into ES 
and this one just generate an Id for every record.

Any example, suggestion, or help would be welcome.

Thanks in advance.

Jose Antonio


Reply via email to