问题描述
我正在使用 https://github.com/zendesk/racecar(在引擎盖下使用 https://github.com/appsignal/rdkafka-ruby,https://github.com/edenhill/librdkafka/ 的 Ruby 包装器)来使用 Kafka 流,并且我不时收到此错误 {{1 }}
Local: UnkNown partition (unkNown_partition)
这个错误似乎是在调用 "/app/vendor/bundle/ruby/2.6.0/gems/rdkafka-0.8.1/lib/rdkafka/consumer.rb:339:in `store_offset'","/app/vendor/bundle/ruby/2.6.0/gems/racecar-2.3.0/lib/racecar/consumer_set.rb:51:in `store_offset'"
时引发的,负责 rd_kafka_offset_store
。
使用 store offset of a message to be used in the next commit of this consumer
检查日志看起来上面的错误总是在前面:
config.log_level = "debug"
第一次在这里使用 Kafka,我不知道会是什么。
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)