小编Mat*_*ley的帖子

我有一个按计划创建的 Kafka 消费者。它尝试使用自上次提交以来添加的所有新消息。

我想在消费完日志中的所有新消息后关闭消费者，而不是无限期地等待新消息进入。

我无法通过 Kafka 的文档找到解决方案。

我在 Confluence.Kafka.ConsumerConfig 和 ClientConfig 类中看到许多与超时相关的属性，包括 FetchWaitMaxMs，但无法破译要使用哪些属性。我正在使用 .NET 客户端。

任何意见，将不胜感激。