使用Spring-Kafka等待消息的API

Question

我使用Spring Boot 2.0.7和Spring-Kafka来创建请求/应答模式。基本上，前端UI向API发出请求，API将消息放到请求Kafka队列中，消息由后端进程处理，完成后将消息放到应答队列中。

我想提供的前端用户界面的api，等待，直到响应准备就绪。此时的UI将仅显示一条正在处理的消息。如果响应不可用(例如，2分钟后)，API应该只返回消息不可用错误，我们可以指示用户稍后再来。

我是Spring-Kafka的新手。它允许我创建一个轮询API吗？如果是这样的话，任何示例代码都将非常感谢。

Answer 1

它不像轮询主题以获得回复那么简单，因为您必须将请求/回复关联起来。

您可以使用ReplyingKafkaTemplate.sendAndReceive()并继续检查Future<?>上的isDone()方法。

如果您希望自己进行轮询，则必须从消费者工厂创建一个消费者对象。