kafka.common.offsetAutoFrangeException-无正当理由

z9smfwbn  于 2021-06-07  发布在  Kafka
关注(0)|答案(0)|浏览(153)

我正在使用 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。我试图删除的主题,日志等,我不断得到这个错误。有人能告诉我怎么处理吗?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题