我有一个微服务架构,其中每个服务的生产者都写入同一个主题。我有两个 kafkaRestproxy 实例,每个实例都收听该主题,但这里的问题是:假设一个请求到达 restproxy 的实例 1,它将重定向到微服务,并且该服务完成了工作并写入对主题的响应但是响应由restproxy的第二个实例消耗,比如说instance-2。
我应该怎么做才能解决这个问题?它们是我们可以附加到请求的任何类型的 application_id 吗,所以当该微服务完成工作并且如果另一个 restproxy 实例消耗了该响应,那么我们可以将响应重定向到那个获取该请求的 restproxy 实例?