Tag: kafka consumer api

kafka节点使用者收到offsetOutOfRange错误

我正在使用kafka-node（kafka的节点客户端），使用消费者检索有关主题的消息。 不幸的是，我收到一个“offsetOutOfRange”条件（调用offsetOutOfRangecallback）。 我的申请工作正常，直到消费者显着滞后于生产者，在最早和最近的抵消之间留下了一个较大的差距。 在这一点上，我（可能错误地）认为消费者将能够继续接收消息（希望赶上生产者）。 我的客户客户代码如下： : : var kafka = require('kafka-node'); var zookeeper = "10.0.1.201:2181"; var id = "embClient"; var Consumer = kafka.Consumer; var client = new kafka.Client(zookeeper, id); var consumer = new Consumer( client, [ { topic: "test", partition: 0 } ], { autoCommit: false } ); consumer.on('error', [error callback…]); consumer.on('offsetOutOfRange', [offset error callback…]); […]

kafka错误：请求偏移量X，但是我们只有从Y到Z范围内的日志段

我有工作kafka实例，但现在它产生成千上万的错误，如下所示： [2016-06-24 01：33：28,092] ERROR [代理0上的副本pipe理器]：在处理来自消费者的分区[test-topic，0]偏移45的提取请求时出错，相关标识为85452.可能的原因： 45，但我们只有0到0范围内的日志段。（kafka.server.ReplicaManager） 我正在使用默认configuration。 我在node.js代码中使用了几个主题。 UPD：重新安装卡夫卡帮助我，但我想知道问题的原始来源。