我使用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)```
但是它仍然没有得到最新的消息,我怎么能只从消费者那里得到最新的消息呢?
暂无答案!
目前还没有任何答案,快来回答吧!