ruby kafka分析错误

oaxa6hgo  于 2021-06-07  发布在  Kafka
关注(0)|答案(0)|浏览(389)

我试图用ruby解析一个Kafka主题。
我的代码:

require 'kafka'

kafka = Kafka.new(seed_brokers: ["someserver"])

kafka.each_message(topic: "topicname") do |message|
  puts message.offset, message.key, message.value
end

我得到以下错误:

/Users/someuser/.rbenv/versions/2.4.2/lib/ruby/2.4.0/optparse.rb:1644:in `parse!': unknown keywords: seed_brokers, client_id (ArgumentError)
from /Users/someuser/.rbenv/versions/2.4.2/lib/ruby/gems/2.4.0/gems/kafka-0.0.2/lib/kafka.rb:66:in `parse'
    from /Users/someuser/.rbenv/versions/2.4.2/lib/ruby/gems/2.4.0/gems/kafka-0.0.2/lib/kafka.rb:16:in `initialize'
    from KafkaConnect.rb:4:in `new'
    from KafkaConnect.rb:4:in `<main>'

不知道是什么问题,我已经检查了文件,似乎没有问题。
我还检查了使用Kafka卡特,它能够流的数据没有任何问题。挑战在于鲁比。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题