node.js - 无限循环 Kafka Consumer

Question

我正在测试一些基本的 Kafka 功能，我有在 Ubuntu Server 18.04 LTS 虚拟机上运行的基础 zookeeper/kafka 服务器。我使用 kafka-node 模块。

此脚本应该等待新消息到达以便使用它。但是我一启动它就陷入了无限循环。

我找不到它的来源，

"use strict"
require('dotenv').config();
var kafka = require('kafka-node');

const client = new kafka.Client("localhost:2181");
var topics = [{
  topic: 'stuff',
  offset: 0
}];
var options = {
  autoCommit: false
}
const HLConsumer = new kafka.HighLevelConsumer(client, topics, options);

HLConsumer.on('message', function(message) {
  console.log(message);
});

HLConsumer.on('error', function(err) {
  console.log('error', err);
});

HLConsumer.on('offsetOutOfRange', function(err) {
  console.log('offsetOutOfRange:', err);
})

祝大家有个愉快的一天，谢谢

编辑 1:

我按要求将 autoCommit 更新为 true，但仍然有问题。这是问题的廉价 gif，实际上它遍历每个偏移量，然后读取偏移量为 0 的 10/15 消息，然后在主题的每个偏移量上重新开始循环

Answer 1

我以前遇到过这个问题，解决方案是更新 kafka-node。