node.js - 如果启用了统计信息，消费者将停止 - node-rdkafka

Question

我node-rdkafka用来消费来自 kafka 的消息。statistics.interval.ms如果设置，消费者进程退出。

这是代码：

const { KafkaConsumer } = require('node-rdkafka')
const consumer = new KafkaConsumer(
    {
        'group.id': 'kafka',
        'metadata.broker.list': 'localhost:9092',
        'statistics.interval.ms': 5000,
    },
    {},
)
consumer
    .on('ready', () => {
        consumer.subscribe(['test1'])
        setInterval(() => {
            consumer.consume(1)
        }, 1000)
    })
    .on('data', (data) => {
        console.log('Message found!  Contents below.')
        console.log(data.value.toString())
    })
    .on('error', (e) => console.log(e))

此代码仅使用一条消息然后退出。我也检查了process.on事件，但没有引发错误。如果我删除'statistics.interval.ms': 5000，那么一切正常

Answer 1

这是windows相关的问题。Linux工作得很好。

Answer 2

consumer
    .on('ready', () => {
        consumer.subscribe(['test1'])
            consumer.consume()
    })
    .on('data', (data) => {
        console.log('Message found!  Contents below.')
        console.log(data.value.toString())
    })
    .on('error', (e) => console.log(e))

试试这个，让我知道它是否适合你。