使用SpringKafka等待消息的api

blpfk2vs  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(342)

我正在使用springboot2.0.7和springkafka创建一个请求/应答模式。基本上,前端ui向api发出请求,api将消息放入请求kafka队列,消息由后端进程处理,完成后,消息将放入应答队列。
我想为前端ui提供一个api,等待响应准备就绪。此时的ui将只显示一条处理消息。如果响应不可用(例如,2分钟后),api应该只返回一个消息not available error,我们可以指示用户稍后返回。
我对Spring的Kafka有点陌生。它允许我创建一个轮询api吗?如果是这样,任何示例代码都将非常感谢。

kyvafyod

kyvafyod1#

它不像轮询一个主题来获得回复那么简单,因为您必须关联请求/回复。
你可以用 ReplyingKafkaTemplate.sendAndReceive() 继续检查 isDone() 上的方法 Future<?> .
如果你想自己投票,你必须从消费者工厂创建一个消费者对象。

相关问题