不为失败找理由,要为成功找方法。

logstash 写 ES 出现 mapper_parsing_exception 如何将此条数据写入到文件中

Elasticsearch | 作者 sardineYJA | 发布于2021年01月20日 | 阅读数:2296

ES ,logstash 版本 6.1.1
logstash 消费 kafka 数据并写入 ES , 出现下面错误:

[WARN ][logstash.outputs.elasticsearch] Could not index event to Elasticsearch. {:status=>400, :action=>["index", {:_id=>nil, :_index=>"index_write", :_type=>"doc", :_routing=>nil}, #<LogStash::Event:0x35077478>], :response=>{"index"=>{"_index"=>"index-2021.01.12-000040", "_type"=>"doc", "_id"=>"F6wQG3cBUuIYkiz0JU1v", "status"=>400, "error"=>{"type"=>"mapper_parsing_exception", "reason"=>"failed to parse [logDay]", "caused_by"=>{"type"=>"number_format_exception", "reason"=>"For input string: \"/common/part.lzo\""}}}}}

请问有什么办法可以让出现写入错误的数据写到一个文件中。
已邀请:

yj7778826 - 苦逼小运维

赞同来自:

开启DLQ,二次处理

要回复问题请先登录注册