Logstash avro decode avro fails

Elastic Stack Logstash
1

An unexpected error occurred! {:error=>#<ArgumentError: negative length -49 given>, :backtrace=>["org/jruby/ext/stringio/StringIO.java:829:in read'", "/local/apps/rtdtuser/resources/elk/logstash-5.3.1/vendor/bundle/jruby/1.9/gems/avro-1.8.2/lib/avro/io.rb:106:inread'", "/local/apps/rtdtuser/resources/elk/logstash-5.3.1/vendor/bundle/jruby/1.9/gems/avro-1.8.2/lib/avro/io.rb:93:in read_bytes'", "/local/apps/rtdtuser/resources/elk/logstash-5.3.1/vendor/bundle/jruby/1.9/gems/avro-1.8.2/lib/avro/io.rb:99:inread_string'", "/local/apps/rtdtuser/resources/elk/logstash-5.3.1/vendor/bundle/jruby/1.9/gems/avro-1.8.2/lib/avro/io.rb:361:in read_map'", "org/jruby/RubyFixnum.java:275:intimes'", "/local/apps/rtdtuser/resources/elk/logstash-5.3.1/vendor/bundle/jruby/1.9/gems/avro-1.8.2/lib/avro/io.rb:360:in read_map'", "/local/apps/rtdtuser/resources/elk/logstash-5.3.1/vendor/bundle/jruby/1.9/gems/avro-1.8.2/lib/avro/io.rb:308:inread_data'", "/local/apps/rtdtuser/resources/elk/logstash-5.3.1/vendor/bundle/jruby/1.9/gems/avro-1.8.2/lib/avro/io.rb:384:in read_record'", "org/jruby/RubyArray.java:1613:ineach'", "/local/apps/rtdtuser/resources/elk/logstash-5.3.1/vendor/bundle/jruby/1.9/gems/avro-1.8.2/lib/avro/io.rb:382:in read_record'", "/local/apps/rtdtuser/resources/elk/logstash-5.3.1/vendor/bundle/jruby/1.9/gems/avro-1.8.2/lib/avro/io.rb:310:inread_data'", "/local/apps/rtdtuser/resources/elk/logstash-5.3.1/vendor/bundle/jruby/1.9/gems/avro-1.8.2/lib/avro/io.rb:384:in read_record'", "org/jruby/RubyArray.java:1613:ineach'", "/local/apps/rtdtuser/resources/elk/logstash-5.3.1/vendor/bundle/jruby/1.9/gems/avro-1.8.2/lib/avro/io.rb:382:in read_record'", "/local/apps/rtdtuser/resources/elk/logstash-5.3.1/vendor/bundle/jruby/1.9/gems/avro-1.8.2/lib/avro/io.rb:310:inread_data'", "/local/apps/rtdtuser/resources/elk/logstash-5.3.1/vendor/bundle/jruby/1.9/gems/avro-1.8.2/lib/avro/io.rb:275:in read'", "/local/apps/rtdtuser/resources/elk/logstash-5.3.1/vendor/bundle/jruby/1.9/gems/logstash-codec-avro-3.2.3-java/lib/logstash/codecs/avro.rb:77:indecode'", "/local/apps/rtdtuser/resources/elk/logstash-5.3.1/vendor/bundle/jruby/1.9/gems/logstash-input-kafka-5.1.6/lib/logstash/inputs/kafka.rb:241:in thread_runner'", "file:/local/apps/rtdtuser/resources/elk/logstash-5.3.1/vendor/jruby/lib/jruby.jar!/jruby/java/java_ext/java.lang.rb:12:ineach'", "/local/apps/rtdtuser/resources/elk/logstash-5.3.1/vendor/bundle/jruby/1.9/gems/logstash-input-kafka-5.1.6/lib/logstash/inputs/kafka.rb:240:in `thread_runner'"]}

Logstash 6.2.2
Kafka 2.11-1.1.1
messages serialized using avro serialization
kafka input

            key_deserializer_class => "org.apache.kafka.common.serialization.ByteArrayDeserializer"
           value_deserializer_class => "org.apache.kafka.common.serialization.ByteArrayDeserializer"
             codec => avro {
              schema_uri => "tweet.schema"
          }
2

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