我正在使用 kafka-node
使用node.js中的kafka消息的库。这是我尝试使用的简单代码:
consumer = new Consumer(
client,
[
{ topic: 't', partition: 0 }, { topic: 't1', partition: 1 }
],
{
autoCommit: false
}
);
consumer.on('message', function (message) {
console.log(message);
});
这在以前的某个时候工作得很好,但现在我不断地得到这个错误:
kafka.common.offsetAutoFrangeException:请求偏移量19,但我们只有0到0范围内的日志段。
我不明白是什么让Kafka在没有任何理由的情况下抛出这个错误,因为之前的代码是一样的,我没有给出偏移量19 no where。我试图删除的主题,日志等,我不断得到这个错误。有人能告诉我怎么处理吗?
暂无答案!
目前还没有任何答案,快来回答吧!