ользую logstash для индексации данных из postgres (входной плагин jdbc) вasticsearch. У меня нет никакой временной информации в базе данных. Пользователи таблицы Postgres для импорта имеют 2 столбца - userid (уникальный), uname Экспорт эластичного поиска - _id = userid Я экспортирую эти данные каждый час, используя расписание cron в logstash.

input {
     jdbc {
         schedule => "0 */1 * * *"
         statement => "SELECT userid, uname FROM users"
     }
}
output {
     elasticsearch {
        hosts => ["elastic_search_host"]
        index => "user_data"
        document_id => "%{userid}"
    }
}

Эта конфигурация logstash правильно индексирует данные. Но это работает только для случаев обновления и вставки. Если какие-либо данные / данные пользователя будут удалены из таблицы, документ не будет удален из индекса эластичного поиска. Может кто-нибудь помочь мне с делом об удалении?