Logstash 5.0.1 with kafka 0.9

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:inregister'", "/home/nosuser/ELK/logstash-5.0.1/logstash-core/lib/logstash/pipeline.rb:319:in start_inputs'", "org/jruby/RubyArray.java:1613:ineach'", "/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:instart_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:instart_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:instop'", "/home/nosuser/ELK/logstash-5.0.1/logstash-core/lib/logstash/inputs/base.rb:89:in do_stop'", "org/jruby/RubyArray.java:1613:ineach'", "/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:instop_pipeline'", "/home/nosuser/ELK/logstash-5.0.1/logstash-core/lib/logstash/agent.rb:280:in shutdown_pipelines'", "org/jruby/RubyHash.java:1342:ineach'", "/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:inshutdown'", "/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:inrun'", "/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:inrun'", "/home/nosuser/ELK/logstash-5.0.1/lib/bootstrap/environment.rb:68:in `(root)'"]}

Someone can help me with this problem?

Thanks,
LC

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