微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

通过 Logstash 的架构注册表问题 - 参数数量错误

如何解决通过 Logstash 的架构注册表问题 - 参数数量错误

尝试通过 Logstash 输出 Avro 序列化到 Kafka 连接到我的架构注册表时,我不断收到错误消息。我认为它不能很好地处理服务器给出的异常。我无法获取架构并且程序停止。

我尝试修改第 127 行的 client.rb 以更改它引发异常的方式,但没有成功,我是否必须重新编译所有内容?这是我第一次使用 Ruby,我在 Java/Kotlin 方面...

我已经确认在我的机器上可以访问 SR 的 URI,我什至可以毫无问题地访问 SR 的 UI,并且可以毫无问题地访问架构。我也试过通过 schema_id 但出现同样的问题。

我也在 Revpoint 的 logstash-codec-avro_schema_registry 的 GitHub 上提出了一个问题,但我看到那里还有其他问题没有答案,所以我把这个问题放在这里,希望有 Ruby 背景的人可以提供帮助我解决了这种情况。非常感谢。

Logstash.javapipeline ][main] Pipeline worker error,the pipeline will be stopped {:pipeline_id=>"main",:error=>"(ArgumentError) wrong number of arguments (given 1,expected 2)",:exception=>Java::OrgJrubyExceptions::ArgumentError,:backtrace=>["org.jruby.RubyException.exception(org/jruby/RubyException.java:129)","C_3a_.datos.logstash.vendor.bundle.jruby.$2_dot_5_dot_0.gems.schema_registry_minus_0_dot_1_dot_1.lib.schema_registry.client.request(C:/datos/logstash/vendor/bundle/jruby/2.5.0/gems/schema_registry-0.1.1/lib/schema_registry/client.rb:127)","uri_3a_classloader_3a_.Meta_minus_INF.jruby_dot_home.lib.ruby.stdlib.net.http.start(uri:classloader:/meta-inf/jruby.home/lib/ruby/stdlib/net/http.rb:914)","uri_3a_classloader_3a_.Meta_minus_INF.jruby_dot_home.lib.ruby.stdlib.net.http.start(uri:classloader:/meta-inf/jruby.home/lib/ruby/stdlib/net/http.rb:609)","RUBY.request(C:/datos/logstash/vendor/bundle/jruby/2.5.0/gems/schema_registry-0.1.1/lib/schema_registry/client.rb:101)",... ...

我的 logstash 配置如下:

 file {
   path => "C:/datos/logstash/out/logfile.json"
   codec => "json_lines"
 }
 kafka {
   acks => "1"
   bootstrap_servers => "my Kafka servers"
   topic_id => "my Kafka topic"
   compression_type => "gzip"
   retries => 0
   codec => avro_schema_registry {
     endpoint=> "schema registry URI"
     subject_name => "the AVRO schema in SR"
     schema_version => "5"
   }
   value_serializer => "org.apache.kafka.common.serialization.ByteArraySerializer"
 }

编辑:我已经从 Unix(我开始开发的地方)和我的本地 Windows 测试了这个过程,并使用了一个虚拟输入,结果相同(我还从 Unix 和 Win 连接到了 SR 服务器)。我可以尝试的任何事情,我都可以在我的 Win 部署中快速完成。

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。