我正在使用springboot2.0.7和springkafka创建一个请求/应答模式。基本上,前端ui向api发出请求,api将消息放入请求kafka队列,消息由后端进程处理,完成后,消息将放入应答队列。
我想为前端ui提供一个api,等待响应准备就绪。此时的ui将只显示一条处理消息。如果响应不可用(例如,2分钟后),api应该只返回一个消息not available error,我们可以指示用户稍后返回。
我对Spring的Kafka有点陌生。它允许我创建一个轮询api吗?如果是这样,任何示例代码都将非常感谢。
1条答案
按热度按时间kyvafyod1#
它不像轮询一个主题来获得回复那么简单,因为您必须关联请求/回复。
你可以用
ReplyingKafkaTemplate.sendAndReceive()
继续检查isDone()
上的方法Future<?>
.如果你想自己投票,你必须从消费者工厂创建一个消费者对象。