- detect when an index is corrupt (index.flush throws an exception),   log a fatal error, and kill the entire logstashd process.
- detect when an index is corrupt (index.flush throws an exception),
  log a fatal error, and kill the entire logstashd process.


opentable/logstash-kafka,Aloomaio/logstash-kafka,joekiller/logstash-kafka,joekiller/logstash-kafka,opentable/logstash-kafka,Aloomaio/logstash-kafka,tinglinux/logstash-kafka,tinglinux/logstash-kafka