Вот оператор select, который представляет собой данные транзакции, каждый раз, когда данные вставляются в UserProfile, старые значения индекса удаляются из эластичного
jdbc {
statement => "SELECT userId,salesTeam FROM UserProfile with (nolock)"
}
output {
elasticsearch {
hosts => ["localhost:9200"]
index => "q_d"
document_type => "cd"
document_id => "%{userId}%"
}
stdout { codec => rubydebug }
}
Я хочу обновить существующие документы, если есть какие-либо изменения, в противном случае проиндексировать новый документ.
Что я делаю неправильно?