apache-kafka - KafkaRestProxy 多实例问题

Question

我有一个微服务架构，其中每个服务的生产者都写入同一个主题。我有两个 kafkaRestproxy 实例，每个实例都收听该主题，但这里的问题是：假设一个请求到达 restproxy 的实例 1，它将重定向到微服务，并且该服务完成了工作并写入对主题的响应但是响应由restproxy的第二个实例消耗，比如说instance-2。

我应该怎么做才能解决这个问题？它们是我们可以附加到请求的任何类型的 application_id 吗，所以当该微服务完成工作并且如果另一个 restproxy 实例消耗了该响应，那么我们可以将响应重定向到那个获取该请求的 restproxy 实例？

标签： apache-kafkakafka-rest

Answer 1

与任何其他应用程序一样，您的代理构成一个 Kafka 消费者组。

您通常不应试图严格控制哪些消费者获得哪些信息

此外，除非您有另一个请求该信息的应用程序，否则其余代理不会消耗任何内容