Estou usando o logstash para indexar dados do postgres (plugin de entrada jdbc) no elasticsearch. Não tenho nenhuma informação baseada em tempo no banco de dados. Os usuários da tabela do Postgres a serem importados têm 2 colunas - identificação do usuário (exclusiva), exportação de pesquisa Elastic uname - _id = userid Estou exportando esses dados a cada hora, usando a programação cron no logstash.

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

Esta configuração do logstash indexa os dados corretamente. Mas, ele funciona apenas para atualizar e inserir casos. Se alguma informação de dados / usuário for excluída da tabela, ela não excluirá o documento do índice de pesquisa elástico. Alguém pode me ajudar com o caso de exclusão?