We keep running into issues where after a while some of our logstash nodes that are reading from kafka, parsing the data, and sending to ES stop processing new requests. This is what were seeing in the logs:
{
  "inflight_count"=>1500, 
  "stalling_thread_info"=>{
    [
      "LogStash::Filters::Mutate", 
      {
        "remove_field"=>["beat", "input_type", "fields", "msg", "name", "time", "timestamp", "v"]
      }
    ]=>[
        {
          "thread_id"=>582, 
          "name"=>"[main]>worker0", 
          "current_call"=>"[...]/vendor/bundle/jruby/1.9/gems/manticore-0.6.0-java/lib/manticore/response.rb:50:in `call'"
        }, 
        {
          "thread_id"=>583, 
          "name"=>"[main]>worker1", 
          "current_call"=>"[...]/vendor/bundle/jruby/1.9/gems/logstash-core-2.4.0-java/lib/logstash/output_delegator.rb:128:in `pop'"
        }
      ]
    }
Is there any way to debug what's happening here?
Thanks!