Open zjxlinux opened 4 years ago
版本: Logstash6.0.0 (Kafka Client 0.11.0) 满足文档定义的版本要求 使用新版DTS订阅服务 input { kafka { bootstrap_servers => ["xxxx"] group_id => "xxxx" security_protocol => "SASL_PLAINTEXT" sasl_mechanism => "PLAIN" jaas_path => "/home/server/logstash-6.0.0/config/logstash_jaas.conf" topics => ["xxxx"] codec => avro { schema_uri => "/home/server/logstash-6.0.0/config/record.avsc" } } }
output { stdout { codec => rubydebug } }
报错如下
[2020-06-11T19:38:03,580][FATAL][logstash.runner ] An unexpected error occurred! {:error=>#<NoMethodError: undefined method type_sym' for nil:NilClass>, :backtrace=>["/home/server/logstash-6.0.0/vendor/bundle/jruby/2.3.0/gems/avro-1.9.2/lib/avro/schema_compatibility.rb:36:inmatch_schemas'", "/home/server/logstash-6.0.0/vendor/bundle/jruby/2.3.0/gems/avro-1.9.2/lib/avro/io.rb:240:in match_schemas'", "/home/server/logstash-6.0.0/vendor/bundle/jruby/2.3.0/gems/avro-1.9.2/lib/avro/io.rb:257:inread_data'", "/home/server/logstash-6.0.0/vendor/bundle/jruby/2.3.0/gems/avro-1.9.2/lib/avro/io.rb:355:in read_union'", "/home/server/logstash-6.0.0/vendor/bundle/jruby/2.3.0/gems/avro-1.9.2/lib/avro/io.rb:286:inread_data'", "/home/server/logstash-6.0.0/vendor/bundle/jruby/2.3.0/gems/avro-1.9.2/lib/avro/io.rb:252:in read'", "/home/server/logstash-6.0.0/vendor/bundle/jruby/2.3.0/gems/logstash-codec-avro-3.2.3-java/lib/logstash/codecs/avro.rb:77:indecode'", "/home/server/logstash-6.0.0/vendor/bundle/jruby/2.3.0/gems/logstash-input-kafka-8.0.2/lib/logstash/inputs/kafka.rb:254:in block in thread_runner'", "/home/server/logstash-6.0.0/vendor/bundle/jruby/2.3.0/gems/logstash-input-kafka-8.0.2/lib/logstash/inputs/kafka.rb:253:inblock in thread_runner'"]}
type_sym' for nil:NilClass>, :backtrace=>["/home/server/logstash-6.0.0/vendor/bundle/jruby/2.3.0/gems/avro-1.9.2/lib/avro/schema_compatibility.rb:36:in
match_schemas'", "/home/server/logstash-6.0.0/vendor/bundle/jruby/2.3.0/gems/avro-1.9.2/lib/avro/io.rb:257:in
read_union'", "/home/server/logstash-6.0.0/vendor/bundle/jruby/2.3.0/gems/avro-1.9.2/lib/avro/io.rb:286:in
read'", "/home/server/logstash-6.0.0/vendor/bundle/jruby/2.3.0/gems/logstash-codec-avro-3.2.3-java/lib/logstash/codecs/avro.rb:77:in
block in thread_runner'", "/home/server/logstash-6.0.0/vendor/bundle/jruby/2.3.0/gems/logstash-input-kafka-8.0.2/lib/logstash/inputs/kafka.rb:253:in
版本: Logstash6.0.0 (Kafka Client 0.11.0) 满足文档定义的版本要求 使用新版DTS订阅服务 input { kafka { bootstrap_servers => ["xxxx"] group_id => "xxxx" security_protocol => "SASL_PLAINTEXT" sasl_mechanism => "PLAIN" jaas_path => "/home/server/logstash-6.0.0/config/logstash_jaas.conf" topics => ["xxxx"] codec => avro { schema_uri => "/home/server/logstash-6.0.0/config/record.avsc" } } }
output { stdout { codec => rubydebug } }
报错如下
[2020-06-11T19:38:03,580][FATAL][logstash.runner ] An unexpected error occurred! {:error=>#<NoMethodError: undefined method
type_sym' for nil:NilClass>, :backtrace=>["/home/server/logstash-6.0.0/vendor/bundle/jruby/2.3.0/gems/avro-1.9.2/lib/avro/schema_compatibility.rb:36:in
match_schemas'", "/home/server/logstash-6.0.0/vendor/bundle/jruby/2.3.0/gems/avro-1.9.2/lib/avro/io.rb:240:inmatch_schemas'", "/home/server/logstash-6.0.0/vendor/bundle/jruby/2.3.0/gems/avro-1.9.2/lib/avro/io.rb:257:in
read_data'", "/home/server/logstash-6.0.0/vendor/bundle/jruby/2.3.0/gems/avro-1.9.2/lib/avro/io.rb:355:inread_union'", "/home/server/logstash-6.0.0/vendor/bundle/jruby/2.3.0/gems/avro-1.9.2/lib/avro/io.rb:286:in
read_data'", "/home/server/logstash-6.0.0/vendor/bundle/jruby/2.3.0/gems/avro-1.9.2/lib/avro/io.rb:252:inread'", "/home/server/logstash-6.0.0/vendor/bundle/jruby/2.3.0/gems/logstash-codec-avro-3.2.3-java/lib/logstash/codecs/avro.rb:77:in
decode'", "/home/server/logstash-6.0.0/vendor/bundle/jruby/2.3.0/gems/logstash-input-kafka-8.0.2/lib/logstash/inputs/kafka.rb:254:inblock in thread_runner'", "/home/server/logstash-6.0.0/vendor/bundle/jruby/2.3.0/gems/logstash-input-kafka-8.0.2/lib/logstash/inputs/kafka.rb:253:in
block in thread_runner'"]}