.Net Core 中的 Kafka 消费者

Question

我想在我们基于微服务的项目中使用 Kafka 作为消息代理。实施消费者的最佳做法是什么？我们应该在 WebApi 中实现为后台服务添加托管服务还是独立控制台应用程序？由于监听队列的无限循环，出于性能和可扩展性的原因，我怀疑在 API 项目中使用。尽管如此，我必须在 WebApi 中使用模型和 类。为了便于扩展，最好为消费者使用专用线程并使用控制台应用程序。我想知道在 .Net Core 中是否有任何最佳实践或示例来实现 Kafka 消费者？

Answer 1

在 Web 应用程序中，您应该让后台工作线程来处理 consumer instances。

如果您想连续处理 Kafka 记录，则需要无限轮询循环。