从kafka节点获取最新消息

iqjalb3h  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(194)

我使用kafka节点消费者组,有以下选项

```const options = {
            kafkaHost: process.env.KAFKA_HOST,
            autoCommit: false,
            protocol: ['roundrobin'],
            fromOffset: 'latest',
            outOfRangeOffset: 'latest'
        }
    const consumerGroup = new ConsumerGroup(options as any, topic_all)```

但是它仍然没有得到最新的消息,我怎么能只从消费者那里得到最新的消息呢?

暂无答案!

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

相关问题