无限循环卡夫卡消费者

我在测试一些基本的卡夫卡特性,我有基本的 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 但还是有问题。