当前位置: 首页 > 知识库问答 >
问题:

ReplyingKafkaTemplate是否阻塞?

范翰池
2023-03-14

ReplyingKafkaTemplate是否阻塞?有无反应性替代方案?

共有1个答案

年健
2023-03-14

它在正常情况下不会阻塞,它返回一个ListenableFuture,它可用于阻塞(get())或使用listable异步获取回复。

然而,当发送第一条消息时,它将阻止等待主题元数据,因此它不是被动的。

有反应器-Kafka项目,但Spring Kafka目前没有使用它。

我们计划在下一个(2.3)版本中考虑一个pull请求。

 类似资料:
  • 问题内容: 我怀疑这是不允许的,因为我收到“解析错误:语法错误,意外的T_IF输入…”错误。但是我找不到实现目标的方法。这是我的代码: 它的作用是在select元素中显示国家列表,并将United States设置为默认值。我不难过… 问题答案: 您将要使用 的 一个三元运算符,用作简化的IF / Else语句:

  • 问题内容: 根据Java线程状态信息,调用wait()将导致线程进入BLOCKED状态。但是,这段代码将导致(在调用之后)处于等待状态的线程。 我有什么问题吗?有人可以向我解释这种行为吗?任何帮助,将不胜感激! 问题答案: 线程在等待通知。然后,它变为BLOCKED,试图重新进入同步区域,直到所有其他线程都离开。 您发布的链接中的有关部分(关于WAITING): 例如,在某个对象上调用Object

  • 问题内容: Redis非常快。在我的机器上,大多数情况下它的速度与node.js中的本机Javascript语句或函数调用一样快。在node.js中编写常规的Javascript代码很容易/很轻松,因为不需要回调。我不明白为什么使用node.js在Redis中获取/设置键/值数据不那么容易。 假设node.js和Redis在同一台机器上,是否有任何npm库允许使用阻塞调用与node.js上的Red

  • 问题内容: 我想使用redis的pubsub传输一些消息,但不想使用阻止,例如以下代码: 最后一部分将被阻止。我只想检查给定频道中是否有数据,该如何完成?有没有类似的方法? 问题答案: 我认为那不可能。通道没有任何“当前数据”,您订阅了一个通道并开始接收该通道上其他客户端推送的消息,因此它是一个阻塞的API。另外,如果您查看pub / sub 的Redis Commands文档,将会更加清楚。

  • 那么,我是否理解正确:await task.delay()不阻塞调用线程,而是阻塞等待的任务转移到的某个线程? 如果这句话是真的,那么你能给我一个方法,让任务等待一段时间而不阻塞任何线程在等待期间吗?

  • 我对JPA中乐观锁定的好处有点困惑。 我在版本化实体表上用两个线程和一行进行了测试。 这是我的发现: 第二次测试。请注意select语句的添加。 我真的没想到在使用乐观锁定时会发生任何阻塞,但是我的理解是,这里必须有一个数据库事务,以便从 select 语句返回正确的数据。 由于JPA似乎只在绝对必要时输入数据库事务,谁能解释一下乐观锁定的好处是什么?