我试图用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卡特,它能够流的数据没有任何问题。挑战在于鲁比。
暂无答案!
目前还没有任何答案,快来回答吧!