微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

Kafka 错误:未知分区unknown_partition

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