Trouble parsing msgpack input, falling back to plain text

The data coming in through kafka is encoded in msgpack so I try to unpack it using codec.
However, the following error occurs.

  • config

input {
kafka {
zk_connect => "localhost:2181"
topic_id => "topic"
group_id => "test"
codec => "msgpack"
}
}

output {
stdout { }
}

  • error
    [WARN ][logstash.codecs.msgpack ] Trouble parsing msgpack input, falling back to plain text....
    [FATAL][logstash.runner ] An unexpected error occurred! {:error=>#<NoMethodError: undefined method `set' for nil:NilClass....

Did you mean? send>, :backtrace=>["/home/logstash/logstash-6.5.4/vendor/bundle/jruby/2.3.0/gems/logstash-codec-msgpack-3.0.7-java/lib/logstash/codecs/msgpack.rb:36:in decode'", "/home/logstash/logstash-6.5.4/vendor/bundle/jruby/2.3.0/gems/logstash-input-kafka-8.2.1/lib/logstash/inputs/kafka.rb:256:inblock in thread_runner'", "/home1/logstash/logstash-6.5.4/vendor/bundle/jruby/2.3.0/gems/logstash-input-kafka-8.2.1/lib/logstash/inputs/kafka.rb:255:in `block in thread_runner'"]}

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