如何解决Kafka的请求-响应机制？
我们希望使用Kafka作为我们的企业服务总线（ESB）。
我知道kafka的大多数用例都是异步用例。
在我们的系统中，是否仍然可以使用kafka在两个endpoint之间进行请求-响应消息传递？
共有1个答案
我在Kafka中没有明确地这样做，但通常的做法是将制作人注册到一个随机的“回复主题”，发送包含此回复主题的请求消息，并让消费者接受此回复主题并将响应发送到那里。请求者可以在发送等待响应的每条消息后进行阻止。
-
我想用kafka流实现请求-响应模式，我使用spring boot kafka，其中添加了一些数据作为报头，命名为关联id，但是当kafka流API处理请求消息时，报头数据会丢失，无法发送到响应主题！我该怎么解决，还是用另一种方法？？
-
在我的views.py中，我有一个函数，它每次使用不同的响应来调用各种requests.get（） 在我的测试类中，我想做这样的事情，但无法计算出确切的方法调用 步骤1： 验证响应包含“a response”、“b response”、“c response” 如何完成步骤1（模拟请求模块）？
-
我试图使用Wiremock Standalone服务器实现POST REST调用的模拟。我面临这样的挑战，假设post主体包含一个“name”字段及其值，那么在post调用的响应中应该返回相同的值。我的json文件如下所示： 所以，我需要得到值，即794363，但使用上面的方法无法在后响应体中获取它。 我也试过这个: 所以我的问题是，即使我使用正则表达式，它与请求中的任何数字匹配，如何使用Wire
-
介绍 YurunHttp 的请求响应类，结果类。除了遵循 PSR-7 规范，另外还增加了一些人性化的方法。 类：Yurun\Util\YurunHttp\Http\Response use Yurun\Util\HttpRequest; $http = new HttpRequest; $response = $http->get('http://www.baidu.com'); 方法 响应内
-
TLDR：有一个请求/响应模式。目前，请求是通过激活队列完成的，响应是通过memcache键值存储完成的（由前端轮询）。出于各种原因，想转移到kafka，想知道我们是否可以重新构建响应路径，以不使用memcach。 我试图理解什么是针对以下问题的最佳实践系统设计。 我们有一个前端，可以生成需要大量处理的请求。应用程序需要响应才能升级。有时，我们需要撤消/后退（这会使您回到以前的状态）。有一组后端可
-
问题内容： 如何检索请求的响应标头？以下是我提出的要求。 提前致谢！ 问题答案： 如果响应为类型，则可以从获取标头。 因此，当您使用Alamofire responseJSON时，可以像这样访问NSHTTPURLResponse属性： 正如苹果文件所说： 包含所有HTTP标头字段的字典，该字段作为服务器响应的一部分收到。通过检查此词典，客户端可以看到HTTP服务器返回的“原始”标头信息。 该词典中