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}"
	}
}