我想建立一个基于微服务和Kafka的互联系统。
所以我有一个api网关来获取http请求，阻止http连接->将请求发送到kafka主题“from-a”->服务a从这个主题读取并将结果返回到主题“result-a”->api网关应该读取这个消息，找到等待响应的连接并将其发送回客户端。
问题是，如果我们有多个api网关服务示例，我们如何匹配具有http客户端连接的示例和具有消息的kafka主题。
看起来所有api网关示例都应该读取kafka主题“result-a”的所有分区并过滤无用的消息？但它不是最优的、cpu密集型的，而且不可扩展。