通过logstash让文本内容在ES上自动换行显示

ES上神奇的换行控制

修改logstash上的conf文件中的内容，最主要的是filter中的条件

input {
	kafka {
		bootstrap_servers => "kafka地址和端口"
		topics => ["topic名字"]
		consumer_threads => 10
		#codec => "json"
	}
}
 
filter {
	mutate { 
		#这里必须一个手动换行，不能使用\n等符号，否则es不能自动换行
		gsub => [ "message", "\\n", "
	" ] }
}

output {
	elasticsearch {
		user => 用户名
		password => 密码
		pool_max => 最大线程数
		pool_max_per_route => 200
		hosts => ["输出的es地址和端口"]
		index => "es的索引名-%{+YYYY.MM.dd}"
	}
}