java - Kafka 用于服务间通信。定向通信问题
问题描述
我想构建基于微服务和Kafka的系统进行内部通信。
所以我有获取HTTP请求的API网关，阻止http连接->向Kafka主题“from-A”发送请求->服务A从该主题读取并将结果返回到主题“result-A”->API网关应该阅读这个message ，找到等待响应的连接并将其发送回客户端。
如果我们有多个 API Gateway 服务实例，我们如何匹配具有 http 客户端连接的实例和具有消息的 kafka 主题。
看起来所有 api 网关实例都应该读取 kafka 主题“result-A”的所有分区并过滤无用消息？但它不是最优的，CPU 密集型且不可扩展。
解决方案
推荐阅读
- tkinter - 如何在我的游戏中添加屏幕计时器？
- javascript - 自定义模块中的 EventEmitter 抛出“.on(...) 不是函数”
- swift - 使用 Swift 进行 Cocoa 打印：“任何”打印机设置的边距/页面大小不规则，有什么解决方法吗？
- azure - 如何从 wwwroot azure app services 下创建的子文件夹启动我的应用程序
- firebase - Firebase 功能：无法加载默认凭据
- git - SourceTree中的提交太多，如何删除它们？
- boost - moodle左侧的块
- firebase - 即使文档字段在 Firestore 安全规则中不可用，如何允许访问？
- php - 在 WooCommerce 中将特定产品添加到购物车之前清空购物车
- java - DatainputStream的readUTF()方法，单独读取文本数据，会报EOF异常。为什么？