Logstash kafka input to elasticsearch output stops consuming

Are you able to try 2.1.X? I wonder if there is a threading/pipeline issue. Also configs are helpful for reference.