.Net Core中的Kafka消费者[关闭]

Question

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

Answer 1

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

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