logstash5.0使用kafka input插件出现异常

An unexpected error occurred! {:error=>#<NoMethodError: undefined method `each' for nil:NilClass>, :backtrace=>["/usr/share/logstash/vendor/bundle/jruby/1.9/gems/logstash-input-kafka-4.0.0/lib/logstash/inputs/kafka.rb:149:in `stop'", "/usr/share/logstash/logstash-core/lib/logstash/inputs/base.rb:89:in `do_stop'", "org/jruby/RubyArray.java:1613:in `each'", "/usr/share/logstash/logstash-core/lib/logstash/pipeline.rb:374:in `shutdown'", "/usr/share/logstash/logstash-core/lib/logstash/agent.rb:267:in `stop_pipeline'", "/usr/share/logstash/logstash-core/lib/logstash/agent.rb:280:in `shutdown_pipelines'", "org/jruby/RubyHash.java:1342:in `each'", "/usr/share/logstash/logstash-core/lib/logstash/agent.rb:280:in `shutdown_pipelines'", "/usr/share/logstash/logstash-core/lib/logstash/agent.rb:130:in `shutdown'", "/usr/share/logstash/logstash-core/lib/logstash/runner.rb:273:in `execute'", "/usr/share/logstash/vendor/bundle/jruby/1.9/gems/clamp-0.6.5/lib/clamp/command.rb:67:in `run'", "/usr/share/logstash/logstash-core/lib/logstash/runner.rb:174:in `run'", "/usr/share/logstash/vendor/bundle/jruby/1.9/gems/clamp-0.6.5/lib/clamp/command.rb:132:in `run'", "/usr/share/logstash/lib/bootstrap/environment.rb:68:in `(root)'"]}