Kafka同步发送vs飞行请求

文章/答案/技术大牛

发布

2回答

java、apache-kafka、kafka-producer-api

如果我使用以下命令同步发送消息 producer.send(myRecord).get(); 我能保证消息会以与发送时相同的顺序到达各个分区吗？只有在第一条记录失败或成功之后，第二条记录才会被处理/发送到代理。

浏览 31提问于2021-04-18得票数 1

回答已采纳

1回答

max.in.flight.request.per.connection配置对同步发送有意义吗？

apache-kafka、kafka-producer-api

max.in.flight.request.per.connection：控制生产者将在不接收响应的情况下向服务器发送多少批消息。如果我在同步模式下使用producer (在这里，我在发送下一批之前等待回复)，这种配置有意义吗？(因为在任何特定时间，飞行请求只能有一个)

浏览 4提问于2022-11-05得票数 1

2回答

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

apache-kafka

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

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

1回答

Internet延迟是否将我的客户端限制为每小时120,000个同步事务？

udp、latency

客户机器向我们的服务器发送UDP请求。服务器处理每个请求并发送响应。事务的逻辑要求客户端在发送新请求之前等待响应。即使客户端和服务器机器的所有处理都是即时的，我们的客户似乎仍然平均需要大约30ms才能通过Internet发送/接收往返交易。(它以光速飞行约5580英里。)这是否意味着一个给定的客户平均每小时不能做超过大约120,000个同步事务？120,000事务=1小时

浏览 2提问于2012-09-12得票数 1

回答已采纳

1回答

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

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

1回答

Outlook外接程序:如何将ajax发布到另一个域？

outlook-addin、browser-sync

我正在用外部编辑器(vs代码)和浏览器同步开发Outlook外接程序。当我试图通过ajax发布时，我得到了以下错误：未能加载：对飞行前请求的响应没有通过访问控制检查:请求的资源上没有“访问控制-允许-原产地”标题。因此，“”源是不允许访问的。

浏览 1提问于2018-02-16得票数 0

1回答

Kafka Producer -默认支持多线程？

apache-kafka

我已经使用kafka_2.9.2-0.8.1.1创建了示例kafka同步生产者和消费者组程序。所以我的问题是，我是否需要向生产者添加多线程代码(就像consumergroup类一样)来支持大量的请求？我读到生产者发送方法是线程安全的。那么kafka producer将在内部处理多线程概念，还是开发人员必须显式编码？谢谢，Cdhar

浏览 2提问于2015-02-16得票数 2

1回答

emberJS JSONAPI适配器发送选项而不是GET请求

javascript、ember.js、ember-data、json-api、get-request

我试图向emberJS应用程序中的工作服务器(通过google检查)发出基本请求。但是当我尝试它时，我会得到http 404错误。然后我检查了错误，发现来自客户端的原始请求是选项请求，而不是GET请求。我不相信恩伯是这么多才多艺，因为这应该是一个主要的事情，emberJS应该做-发送请求。任何帮助都会得到认可。

浏览 3提问于2016-04-08得票数 0

回答已采纳

1回答

谁在卡夫卡管理ISR？

apache-kafka

我知道Kafka有管理领导者-追随者数据复制的ISR机制，但我只是想知道到底是谁更新了ISR？

浏览 1提问于2022-01-17得票数 2

回答已采纳

1回答

如果CORS的预飞失败了，是否会发出真正的请求？

javascript、google-chrome、http、browser、cors

如果CORS的预飞失败了，是否会发出真正的请求？浏览器仍然发送真正的请求，但是响应被截获了吗？

浏览 2提问于2017-06-02得票数 0

1回答

角$http.get() -如何捕获“访问控制”错误

angularjs、error-handling、cors

我使用$http.get()来提交一个API请求，只要在测试时在浏览器中启用CORS，这个请求就能正常工作。当然，那只是个绷带。

浏览 1提问于2017-11-15得票数 1

1回答

长轮询避免发送选项和合并[跨域]

javascript、jquery、long-polling

问题是，我需要从sub.example.com向子域( example.com )发送请求。这里的问题是浏览器首先发送一个选项请求，如果服务器响应正常，它将继续进行GET请求(这正是我们想要的)。不过，我想尽量避免第一种选择的要求。在服务器设置中有什么可以允许发生这种情况的吗？

浏览 3提问于2015-12-17得票数 0

回答已采纳

1回答

向带有基本身份验证的Katana托管WebAPI添加cookie

c#、asp.net-web-api、owin、katana

如果下列条件为真，浏览器可以跳过飞行前请求：请求方法是GET、HEAD或POST，应用程序不设置除接受、接受-语言、内容-语言、内容-类型或最后一次事件-ID以外的任何请求标头，而内容-类型标头(如果设置在javascript中，我在服务器接受请求的所有请求上设置了身份验证头(带有jquery、beforeSend)。这意味着上面将发送对所有请求的选项请求。我不想那样。

浏览 1提问于2013-09-16得票数 5

回答已采纳

1回答

可靠消息传递

apache-kafka、kafka-producer-api

我使用Kafka客户端0.9.0.0向Kafka集群发送消息。该系统是一种管道，它消耗来自JMS的消息并将其发送给Kafka。一旦信息被消耗，信息就会被发送给卡夫卡，这就是问题所在。我可以使用Kafka生产者带有回调的异步发送，如果向Kafka发送消息有错误，那么通知JMS使用者不承认消息消费已经太晚了。同步：使用同步调用，在Producer.send()返回的将来调用

浏览 1提问于2016-09-19得票数 0

回答已采纳

5回答

在kafka中发送同步消息？

apache-kafka、kafka-producer-api

如何在kafka中发送同步消息？max.in.flight.requests.per.connection = 1。但我想知道在kafka中是否有一种直接或替代的方式来发送同步消息。(类似于producer.syncSend(...)等)。

浏览 0提问于2017-08-06得票数 7

1回答

具有凭据的jQuery CORS仅在Chrome中工作

jquery、ajax、credentials、cors、request-headers

我的ajax CORS请求面临一个问题。我让它在任何其他浏览器中工作，但是Firefox不发送授权头。serverTestLog').html('<h3><span style="color: green">success</h3>'); }); 问题似乎是，Chrome是唯一一个实际向请求发送授权头的浏览器如果我在Firefox上尝试，它会问我用户名和密码，然后正确地启动一个新的请求，但是我想

浏览 3提问于2012-09-03得票数 3

2回答

我们怎么能用卡夫卡快速写出一条信息(而不是批次)？

go、apache-kafka、kafka-producer-api、segment-io

我是刚接触过Golang和Kafka的人，并且我正在使用segmentio go使用Golang连接到Kafka服务器。到目前为止，我希望在Kafka中推送用户的每个事件，所以我想推送单个消息(而不是批处理)，但是由于这个库提供的写操作对于批处理或单个消息都需要相同的时间，所以需要花费大量的时间。

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

回答已采纳

3回答

用于异步消息传递的Node.js REST API包装器

node.js、rest、express、asynchronous、microservices

给定一个带有异步消息传递的事件驱动的微服务架构，有什么解决方案可以实现“同步”REST API包装器，从而使发送到REST接口的请求在向客户端发送响应之前等待响应事件的发布？示例: POST /api/文章在内部，这将在服务层中发送一个CreateArticleEvent，最终得到一个包含持久化文章ID的ArticleCreatedEvent作为响应。处理多个并发请求--在REST api层中以相关标识符为关键字在内存中保留飞行中请求</e

浏览 0提问于2018-01-28得票数 1

1回答

AngularJS $http.post在Chrome中不工作，只有IE

javascript、angularjs、post、asp.net-web-api

我试图向本地asp.net web.api服务发布一个简单的JSON对象。 createTable: function (table) { res.success(function (data, status, headers, config) { alert("Sent : " + JSON.string

浏览 5提问于2015-03-21得票数 1

回答已采纳

1回答

同步Kafka生产者有例外吗？

apache-kafka、confluent-platform、strimzi

正如您所知道的，有两种发送消息的方式-同步和异步。当我们使用同步模式编写代码时，代码如下所示 producer.send(new ProducerRecord(topicName, event)).get(); 阅读Kafka文档https://kafka.apache.org/10/javadoc/org/apache/kafka/clients/producer/KafkaProduc

浏览 29提问于2021-02-25得票数 1

回答已采纳

点击加载更多