Hi Team,
Im adding the fingerprint of method UUID to avoid the duplication of the data.
Im using kafka as producer and Elasticsearch as consumer.
Example pipeline conf looks like this
input
{
kafka
{
bootstrap_servers => ["xxxxxxx:9093"]
topics => ["xxxxxx"]
......
.......
}
}
filter {
fingerprint {
target => "generated_id"
method => "UUID"
}
}
output {
elasticsearch {
hosts => ["https://xxxxxxxxxx:9200"]
document_id => "%{[generated_id]}"
Using this method we are not able to achieve the deduplication of data on the Elasticsearch side.
Can we solve this problem using any other approach?