问题描述
我有以下用例，但不确定如何处理。
- Kafka生产者为一个主题生成数据，我们称该数据为X
- Kafka消费者阅读它们。
- 使用者将数据发送到服务器以对其执行进一步的操作（繁重的任务），可以说结果对象现在是X1
- 我希望执行操作的服务器将结果通知另一个客户端（反应客户端）。
以下是我考虑过的一些解决方案：
Websockets：我需要由客户端启动一个连接（如果我错了，请纠正我），这不是我构建的流程的一部分。
长时间轮询类似注册表的存储（例如mongo）：当识别出新密钥（例如，按插入日期）时，获取相关数据。
排队：服务器会将处理后的结果放入队列（或者可能在另一个Kafka主题中）。 React将消耗该队列。也许通过Web套接字后端端点（因为将Kafka与react连接起来听起来不太好），它将定期轮询队列并通过WebSocket接收数据。
这些声音如何？任何其他想法表示赞赏。我最终的体系结构目标是要有一个足够好的解决方案，可以相对快速地实施。
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）