node.js - 卡夫卡错误: Request for offset X but we only have log segments in the range Y to Z

标签 node.js apache-kafka kafka-consumer-api kafka-producer-api

我有工作的 kafka 实例,但现在它产生了数千个错误,如下所示:

[2016-06-24 01:33:28,092] ERROR [Replica Manager on Broker 0]: Error when processing fetch request for partition [test-topic,0] offset 45 from consumer with correlation id 85452. Possible cause: Request for offset 45 but we only have log segments in the range 0 to 0. (kafka.server.ReplicaManager)

我正在使用默认配置。我在 Node.js 代码中使用了多个主题。

UPD:重新安装kafka对我有帮助,但我想知道问题的原始根源。

最佳答案

请阅读此处了解问题根源 https://github.com/endgameinc/elasticsearch-river-kafka/issues/8

您可能删除了kafka中的某些文件或文件夹。

关于node.js - 卡夫卡错误: Request for offset X but we only have log segments in the range Y to Z,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/38003060/

相关文章:

Javascript 使用 momentjs 在时区之间进行转换

docker - 无法从 logstash docker 容器连接到 kafka docker 容器

apache-spark - Spark Structured Stream 只从 Kafka 的一个分区获取消息

java - 使用 Kafka Streams 按 ID 和时间连接日志 - 无法刷新状态存储

javascript - 获取 CPU 温度作为 Node 红色中的数字

javascript - 在 Node module.exports 的对象方法中使用 'this'

node.js - 将 Joi 模式与 Mongoose 模式一起使用?

java - 使用kafka的双向消息系统

apache-kafka - 重试Kafka使用者中的逻辑

java - 如何暂停 kafka 消费者?