# Logstash 5.0.1 with kafka 0.9

**URL:** <https://discuss.elastic.co/t/logstash-5-0-1-with-kafka-0-9/67660>\
**Category:** Logstash\
**Created:** [November 30, 2016, 6:07pm UTC](https://discuss.elastic.co/t/logstash-5-0-1-with-kafka-0-9/67660 "2016-11-30T18:07:40Z")\
**Posts on this page:** 2\
**Page:** 1

<div class="post-metadata">

**Author:** ![luis.carvalho](https://avatars.discourse-cdn.com/v4/letter/l/d07c76/32.png) [@luis.carvalho](https://discuss.elastic.co/u/luis.carvalho)\
**Post date:** [November 30, 2016, 6:07pm UTC](https://discuss.elastic.co/t/logstash-5-0-1-with-kafka-0-9/67660/1 "2016-11-30T18:07:40Z")

</div>

Hi!

I have a logstash 5.0.1 installation, and I want to get data from my kafka 0.9, but logstash give me a erro. I already update the kafka plugin to 4.0.0 version.

bin/logstash-plugin remove logstash-input-kafka  
bin/logstash-plugin remove logstash-output-kafka  
bin/logstash-plugin install --version 4.0.0 logstash-input-kafka  
bin/logstash-plugin install --version 4.0.1 logstash-output-kafka

The config file:

input {  
kafka {  
topics =\> ["topic\_name"]  
bootstrap\_servers =\> "10.217.144.33:2181"  
client\_id =\> "logstash\_test"  
}  
}

output {  
stdout {codec =\> rubydebug}  
}

The topic exist and have data on it.

Logstash error:

[ERROR][logstash.agent] Pipeline aborted due to error {:exception=\>#\<NameError: uninitialized constant LogStash::Logger\>, :backtrace=\>["org/jruby/RubyModule.java:2719:in `const_missing'", "/home/nosuser/ELK/logstash-5.0.1/vendor/bundle/jruby/1.9/gems/logstash-input-kafka-4.0.0/lib/logstash/inputs/kafka.rb:136:in`register'", "/home/nosuser/ELK/logstash-5.0.1/logstash-core/lib/logstash/pipeline.rb:319:in `start_inputs'", "org/jruby/RubyArray.java:1613:in`each'", "/home/nosuser/ELK/logstash-5.0.1/logstash-core/lib/logstash/pipeline.rb:318:in `start_inputs'", "/home/nosuser/ELK/logstash-5.0.1/logstash-core/lib/logstash/pipeline.rb:195:in`start\_workers'", "/home/nosuser/ELK/logstash-5.0.1/logstash-core/lib/logstash/pipeline.rb:153:in `run'", "/home/nosuser/ELK/logstash-5.0.1/logstash-core/lib/logstash/agent.rb:250:in`start\_pipeline'"]}

[INFO][logstash.agent] Successfully started Logstash API endpoint {:port=\>9600}

[WARN][logstash.agent] stopping pipeline {:id=\>"main"}

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

Someone can help me with this problem?

Thanks,  
LC

---

<div class="post-metadata">

**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\
**Post date:** [December 28, 2016, 6:07pm UTC](https://discuss.elastic.co/t/logstash-5-0-1-with-kafka-0-9/67660/2 "2016-12-28T18:07:40Z")

</div>

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.