同步到ES 的时候，有收下报错，主要是cluster 没配好 ：

Exception in thread ">output" org.elasticsearch.discovery.MasterNotDiscoveredException: waited for [30s]

at org.elasticsearch.action.support.master.TransportMasterNodeOperationAction$3.onTimeout

(org/elasticsearch/action/support/master/TransportMasterNodeOperationAction.java:180)

at org.elasticsearch.cluster.service.InternalClusterService$NotifyTimeout.run

(org/elasticsearch/cluster/service/InternalClusterService.java:492)

at java.util.concurrent.ThreadPoolExecutor.runWorker(java/util/concurrent/ThreadPoolExecutor.java:1145)

at java.util.concurrent.ThreadPoolExecutor$Worker.run(java/util/concurrent/ThreadPoolExecutor.java:615)

at java.lang.Thread.run(java/lang/Thread.java:745)

解决方法： 

修改Logstash Output属性：（或者修改 elasticsearch.ymf 的 cluster.name:elasticsearch）

　　 elasticsearch { 
    　　host => "127.0.0.1"
   　　 port => 9200
   　　 cluster => "elasticsearch"
 　　 }

修改cluster属性，重启即可！