我开始使用kafkajs和阅读文档 - https://kafka.js.org/docs/sumption
并想问一些关于消费消息的问题。
使用
eachMessage功能时，无需设置autoCommit: false。这是否意味着一旦eachMessage函数读取了一条消息，它就会自动提交？如果我确实 set
autoCommit: false，然后使用commitOffsets我希望提交的每条消息。我是否只需要增加offset我阅读的每条消息的值？fromBeginning当消费者重新启动时，我无法决定在场景中使用哪个值。如果我配置fromBeginning: true，这是否意味着在消费者重启的情况下，它将读取已经提交的消息？
提前致谢。