Kafka 错误:未知分区unknown_partition

问题描述

我正在使用 https://github.com/zendesk/racecar(在引擎盖下使用 https://github.com/appsignal/rdkafka-rubyhttps://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 (将#修改为@)