在kafka中实现HTTP同步请求响应

文章/答案/技术大牛

发布

1回答

c#、.net-core、apache-kafka

我正在研究集装箱化应用程序，其中前端应用程序调用HTTP请求到API网关。API网关收到的请求数据通过Kafka转发给Micro服务。但我必须将响应作为响应发送回API网关，并返回到前端应用程序。请问如何通过Kafka实现API网关和micron服务的同步请求和响应？我尝试过Producer和Consumer，这就像Fire一样，忘记了我无法响应请求的地方。提

浏览 127提问于2020-05-02得票数 1

1回答

卡夫卡客户端库(合-卡夫卡-go)：在auto.offset.reset =最新的情况下，消费者和生产者之间的同步

apache-kafka、confluent-kafka-go

我有一个用例，我想在kafka之上实现同步请求/响应。例如，当用户发送HTTP请求时，我希望在特定的kafka输入主题上生成一条消息，该消息触发数据流，最终生成输出主题上的响应。工作流程是: HTTP请求->在输入主题上生成消息-> (从输入主题消费消息->应用程序逻辑->生成输出主题消息) ->消费消息来自输出主题->

浏览 4提问于2022-11-15得票数 0

1回答

我们能在spring应用中使用spring云流kafka吗？

spring、apache-kafka、spring-cloud-stream-binder-kafka

我在互联网春云流卡夫卡上看到了很多例子。但他们中的大多数人并没有将其作为一个web应用程序使用。它只是一个作为消费者的应用程序。我想知道，如果我在我的web应用程序中使用spring云流kafka，有类似于并发问题的问题吗？如果不推荐，原因是什么？多谢你们的支持

浏览 0提问于2021-06-18得票数 0

回答已采纳

1回答

我正在尝试使用Kafka作为消息代理来实现RPC架构。使用Kafka而不是其他message broker解决方案的决定由当前上下文决定。实际的实现包括两种不同类型的服务： receiver ：此服务接收来自Kafka topic的消息，Kafka topic消费并处理消息，然后将响应消息发布到响应主题； caller：此服务接收HTTP请求，然后将消息发布到receiver主题，消费响应消息的

浏览 151提问于2019-03-26得票数 1

2回答

配置ReplyingKafkaTemplate以从多个主题获取响应

apache-kafka、kafka-consumer-api、spring-kafka

我有一个需求，我必须使用使用Kafka的同步请求-应答模式，因此我使用的是ReplyingKafkaTemplate。作为实现的一部分，有一个生产者正在一个topic(input-message-topic1)上推送请求消息，但作为回报，我期待来自两个topics(output-message-topic1和output-message-topic2)的响应，而我必须对这两个响应进行进一步的聚合和处理。问:是否可以使用ReplyingKafkaTemplate

浏览 6提问于2021-04-29得票数 1

回答已采纳

2回答

客户端到服务器的同步调用和微服务之间的异步调用

client-server、message-queue、synchronous

关于是否使用RMQ/Kafka/Http等在微服务之间进行通信的讨论让我有些不知所措。我希望得到一些关于这方面的见解。首先，我的客户端是一个移动应用程序，它进行同步调用并等待响应。直觉上，我不希望java服务器和Python分类器之间的内部通信是同步的，因为我希望有一个高吞吐量，因为我可以有数千或数百万(希望)同时发送请求的客户端。如何进行非阻塞请求-响应，同时检索对同一客户端的请求？客户端&l

浏览 0提问于2020-03-09得票数 0

1回答

如何在Kafka中实现请求应答(同步)消息传递模式？

python、apache-kafka、synchronous、kafka-python

我将在我的应用程序中使用Kafka作为消息代理。此应用程序完全使用Python编写。对于这个应用程序的一部分(登录和身份验证)，我需要实现一个请求回复消息系统。换句话说，生产者需要同步地从使用者那里获得产生的消息的响应。使用Kafka及其Python库(kafka-python，.)是否可行？

浏览 0提问于2020-11-09得票数 4

1回答

Kafka流处理过程中的外部系统查询

apache-kafka、apache-kafka-streams

要求：我正在探索Kafka和Kafka流，用于流处理和RT/NRT实时消息传递我的问题是:在流处理过程中，我需要对外部系统(信息提供者、MongoDB等)执行一些查询。根据外部系统特性，这些查询可以是同步查询和异步req响应。我读过，解释了如何在处理过程中加入KStream和KTable，这很有趣

浏览 5提问于2017-02-06得票数 9

回答已采纳

1回答

是否有可能获得同步的spark请求-回复响应？

apache-spark

我能够从同步kafka.But获得请求-回复响应我需要从spark应用程序获得相同的响应，在那里我计算aggregations.How来实现这一点？

浏览 5提问于2020-02-18得票数 0

2回答

kafka有异步请求/响应java api吗？

apache-kafka

我们更喜欢在生产者上使用异步请求/响应 public void response(ResponseIf success, ack the upstream kafka}我唯一看到的是将producer.type设置为asynch，但调用只是一个异步请求，没有等待任何响应…… producer.se

浏览 0提问于2014-03-08得票数 7

4回答

Kafka Msg对REST电话

rest、apache-kafka、microservices、kafka-consumer-api、spring-kafka

如今，在微服务世界中，我看到了很多在我的工作场所使用kafka消息传递的设计，当您可以在微服务之间使用rest调用实现类似的结果时。从技术上讲，您可以完全停止使用rest调用，而可以使用kafka消息传递。我真的想知道最佳实践，利弊，什么时候在微服务之间使用api调用，什么时候使用kafka消息传递。每天的供应商服务都会调用供应商API来获取新的项目，而这些项目需要转移到库存服务中。项目数最多可达10,000个对象。从供应商API获得

浏览 0提问于2019-09-09得票数 74

回答已采纳

1回答

如何处理与Spring数据流同步的响应

java、spring、microservices、synchronous、spring-cloud-dataflow

我们正在设计将我们的单块Java应用程序移植到微服务的过程中，以满足各种客户端的需求，如可扩展性、高可用性等。应用程序的核心功能是数据处理，即从源中检索数据，进行0或多个转换，最后将结果推送到目的地。因此，我们看到运行在Kubernetes和Kafka上的Spring数据流为我们做了繁重的工作，使用了一些定制的流应用程序来处理我们的业务逻辑。不过，有一件事我们还没有弄清楚，那就是它如何处理通过HTTP源发送的请求的同步响应--特别是在响应</e

浏览 5提问于2021-12-10得票数 0

回答已采纳

1回答

如何处理数千条消息到C套接字？

sockets、message-queue、tcp

为了处理这个问题，我在NodeJS中实现了一个消息队列(它还将HTTP消息转换为C服务理解的消息，但这是我在C-服务中可能做的次要事情)。清漆很容易处理数千个请求。只要请求排队，C服务就可以满足成千上万的请求。 NodeJS...不是很多。(我尝试过集群，但由于其他实现问题，这不是一种选择。)我一直在研究消息代理，如Kafka/RabbitMQ/Zer

浏览 0提问于2016-06-22得票数 5

回答已采纳

1回答

如何使用Jmeter加载测试Kafka主题

apache-kafka、jmeter、jmeter-plugins

场景:对Kafka的请求读取响应从Kafka请求到Kafka读取从其他MQ请求到其他MQ的响应来自Kafka的读响应有人能帮助我们如何实现这一点，任何设置或其他什么吗？

浏览 2提问于2019-09-05得票数 1

1回答

如何在UFT11.53中使用HTTP* Receiver发送同步响应*

qtp、hp-uft

我正在测试一个web服务，它在请求之后首先发送同步响应，然后在一段时间后发送异步响应。我已经设置了一个用于发送的HTTP请求和一个用于获取异步消息的HTTP接收器。我确实收到了响应消息，但该服务需要一个同步ACK消息，否则它将继续定期发送该消息。我不知道如何将此同步ACK发送回该服务。我所能看到的是，在GUI中没有任何东西可以实现这一点，但奇怪的

浏览 3提问于2014-03-17得票数 1

1回答

gRPC服务器-达到的最大执行器线程数

multithreading、grpc-java

我实现了一个gRPC服务器，它只有一个RPC方法。它接受输入对象(包含在请求中)并将其同步写入Apache主题，这要归功于Kafka客户端生产者API。假设由于临时故障而无法使用Kafka代理，而且gRPC服务器接收了如此多的请求，因此处理它们的所有50个线程都因为对Kafka主题进行同步写重试而被阻塞，所以所有线程都变得繁忙。如果其他请求在所有50个线程都繁忙时到达，会发生什么情况？是否安全地对它们进行排队？是否存

浏览 6提问于2022-02-16得票数 0

1回答

NestJS -拦截器记录传入/传出的卡夫卡事件

nestjs、nestjs-config、kafkajs

我在我的NestJS应用程序中实现了一个拦截器来使用axios拦截器记录http请求/响应在我的应用程序中，有类似的东西可以用来记录传入/传出的kafka事件吗？

浏览 2提问于2022-09-29得票数 0

2回答

如何将RESTful服务器与Apache结合起来？

java、spring-boot、asynchronous、apache-kafka、long-polling

我有两个服务器：第二次检索必要的数据，并在主题"returnData“中

浏览 0提问于2019-01-14得票数 0

5回答

REST web服务:同步还是异步？

java、rest、web-services、asynchronous、synchronization

REST服务的默认行为是同步的还是异步的？如果它是同步的，那么我们能创建异步吗？

浏览 7提问于2013-04-17得票数 37

回答已采纳

1回答

为什么不推荐使用Kafka实现请求/响应模式

.net-core、apache-kafka、microservices、request-response、confluent-kafka-dotnet

有些人不推荐在微服务世界中使用kafka来实现请求/响应模式。这些事件将被发布到三个kafka主题，然后将被三个消

浏览 15提问于2021-09-27得票数 0

点击加载更多