我正在使用https://github.com/zendesk/racecar (其中使用https://github.com/appsignal/rdkafka-ruby 在引擎盖下,一个Ruby Package https://github.com/edenhill/librdkafka/)为了使用Kafka流,我不时收到这个错误 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"` 看起来上面的错误前面总是有:
rdkafka: [thrd:sasl_ssl://a1-abc-d1er1.eu-east-2.aws.confluent.cloud:9092/2]: sasl_ssl://a1-abc-d1er1.eu-east-2.aws.confluent.cloud:9092/2: Disconnected (after 3600185ms in state UP)
(try 1/10): Error for topic subscription #<struct Racecar::Consumer::Subscription topic="my.topic", start_from_beginning=true, max_bytes_per_partition=1048576, additional_config={}>: Local: Broker transport failure (transport)
第一次在这里使用Kafka,我不知道会是什么。
暂无答案!
目前还没有任何答案,快来回答吧!