我有一个Kafka消费者给出了下面的异常。这表明了什么？如何解决？它似乎试图从一个没有任何内容的队列中消费，但我不确定这是如何发生的。
的数据我不知道这是否相关，但我也看到项目没有从一个主题被消费。我有多个主题被消费，所以有一种方法来确定哪个主题收到异常。
tzdcorbm1#
似乎没有为您的消费者组设置偏移量。然后您需要配置策略，从您想要开始读取的位置开始。请参阅KafkaFlow文档中的此部分。https://farfetch.github.io/kafkaflow/docs/guides/consumers/add-consumers#offset-strategy
1条答案
按热度按时间tzdcorbm1#
似乎没有为您的消费者组设置偏移量。然后您需要配置策略，从您想要开始读取的位置开始。请参阅KafkaFlow文档中的此部分。
https://farfetch.github.io/kafkaflow/docs/guides/consumers/add-consumers#offset-strategy