I am using Logstash pipeline to re-index ES 2.1.2 index from cluster A to cluster B. New index is created, but logstash adds it's own @version and @timestamp to records. Is there a way to delete these 2 fields via mutate right before the write. I don't really care when the record was processed by logstash, as this index is a datastore, and I can't have the json altered. The reason I am using logstash, is because snapshot fails on one shard, so I get partial snapshot.
Thanks in advance