如何解决通过 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 举报,一经查实,本站将立刻删除。