search

logstash-plugins / logstash-input-kinesis

Logstash Plugin for AWS Kinesis Input
Apache License 2.0
45 stars 57 forks source link

Problem with Kinesis input plugin #88

Closed rkredux closed 4 years ago

rkredux commented 4 years ago

I have a Logstash pipeline that uses the Kinesis input plugin which is not consuming records from the Kinesis data stream. I set the log level to DEBUG in the pipeilne to find out the issue. Found out the log below which may explain.

Some more details: Logstash version - 7.9.0 Kinesis input plugin version - v2.1.1

[2020-09-01T03:44:56,517][DEBUG][logstash.javapipeline ][cloudwatch] Pipeline terminated by worker error {:pipeline_id=>"cloudwatch", :exception=>#<NoMethodError: undefined methodlogger' for #>, :backtrace=>["/usr/share/logstash/vendor/bundle/jruby/2.5.0/gems/logstash-input-kinesis-2.1.1-java/lib/logstash/inputs/kinesis.rb:78:in register'", "/usr/share/logstash/logstash-core/lib/logstash/java_pipeline.rb:226:inblock in register_plugins'", "org/jruby/RubyArray.java:1809:in each'", "/usr/share/logstash/logstash-core/lib/logstash/java_pipeline.rb:225:inregister_plugins'", "/usr/share/logstash/logstash-core/lib/logstash/java_pipeline.rb:359:in start_inputs'", "/usr/share/logstash/logstash-core/lib/logstash/java_pipeline.rb:309:instart_workers'", "/usr/share/logstash/logstash-core/lib/logstash/java_pipeline.rb:183:in run'", "/usr/share/logstash/logstash-core/lib/logstash/java_pipeline.rb:134:inblock in start'"], "pipeline.sources"=>["/etc/logstash/conf.d/cumulus-cloudwatch-sb-sit.conf"], :thread=>"#<Thread:0x43c79311@/usr/share/logstash/logstash-core/lib/logstash/pipeline_action/create.rb:53 run>"}`

rkredux commented 4 years ago

The stack trace seems to point to a problem with https://github.com/logstash-plugins/logstash-input-kinesis/blob/master/lib/logstash/inputs/kinesis.rb#L78

rkredux commented 4 years ago

This seems to have been resolved with the release of v2.1.2. Can be closed out. Thanks.