Usage scenarios: through logstash from mongo cluster to es cluster synchronization data, Linux environment
Es version: 6.6.0
Logstash version: 6.6.0
Using the plug-in: logstash - input - directing a

Problems in detail: the logstash has been running for a period of time, the data has been part of synchronous error: suddenly directing Input threw an exception, restarting {:=& gt; # & lt; ArgumentError: invalid byte sequence in utf-8 & gt; }

Translation once, say it's chaotic sequence in Chinese in utf-8,
Spot check the mongo repository in this table is not synchronous data, the individual fields exist json string is garbled, but I did not save the field to es, only remove_filed operation,

Pray god to give directions, what to do?
What's the response?
Whether the logstash mongo synchronization es. Conf configuration file Settings mongo coding format?

The couple only 20 points, a great god glad