kafkajs 偏移管理，如何获取单条消息。我到处寻找解决方案，但似乎没有任何效果。谁能帮帮我

Question

我尝试了 kafkajs 文档here 上提供的所有自动提交选项以及相同的手动提交。但对我来说似乎没有任何效果。 是否有任何我可能遗漏的选项，除了文档中提供的那些：https://kafka.js.org/docs/1.11.0/consuming

Answer 1

通过在实例化 Kafka 消费者组 ID 时更改设置解决了该问题。所以问题基本上是，我有不同组 id 的生产者和消费者的实例化。所以，当我让他们使用相同的 Kafka Group ID 进行连接时。它按预期工作。