Update record in Kafka-Elastic Pipelines through Logstash

I am directly ingesting kafka recored from kafka topic to Elasticsearch server, if there is coming records is updated with the existing in Elasticsearch server so how can i handle it with logstash that if creation it ingesting and if updating with existing record it update the record.
eg. existing record in Elasticsearch - > id = 1 , name=jhon and updated record id=1, name=smith
so how can i handle it as we know unique _id is created for each record in Elasticsearch.
sorry for english i hope you understand my question. i am new in Elasticsearch

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.