input {
  elasticsearch {
    hosts       => ""
    index       => "*"
    docinfo     => true
    docinfo_target => "[@metadata][docinfo]"
  }
}

filter {
  mutate {
    # Remove internal fields added by Logstash
    remove_field => ["@version", "@timestamp"]
  }
}

output {
  opensearch {
    hosts       => ""
    index       => "%{[@metadata][docinfo][_index]}"
    document_id => "%{[@metadata][docinfo][_id]}"
    action      => "update"
    doc_as_upsert => true
  }
}