1

我是 Kafka 新手，正在使用 Kafka Dotnet Confluent，考虑到 ASP.NET Core Blazor Server Web 应用程序中的以下架构建筑学

由于与消费者相关的费用，我读过建议每个进程有一个单例 kafka 消费者。这在一个持续进程生命周期的长时间运行的任务中执行。

如果我希望登录的用户能够在应用程序页面上接收更新以监控从 kafka 主题收到的消息……我怎样才能让每个用户的范围服务自动接收消费消息的通知并更新页？

  1. 信号机？
  2. 将事件（对于每个消费的消息）发布到事件总线，例如。NServiceBus、Rebus 等？每个前端页面都会在收到从事件总线收到的事件通知时刷新.....
  3. API 作为 kafka 主题的前端。登录用户的每个前端页面然后频繁轮询 API 以刷新？
4

0 回答 0