logsash报错阻塞

logstash 有时候回有这个错误，不知道是logstash 的处理能力不够，还是elastic search 的存储太慢？

 
请专家解惑,
是否需要增加队列服务，filebeat客户端先把日志消息发送至队列，logstash取；
或着logstash 把处理完的日志放到队列里，elstashsearch 从在队列中获取数据存储；
目前的架构是：
filebeat  -->  logstash01    ---->    elasticsearch01 
....            -->  logstash02    ---->    elasticsearch02
                                              ---->   elasticsearch02