What happen when logstash kafka input die?