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

网状全反应Kafka电抗器

丌官远
2023-03-14

我在quora上看到一个帖子,对我有什么影响?我的完全反应性项目会有问题吗?

https://www.quora.com/why-do-so-many-developers-dislike-apache-kafka

主要的一点是,Kafka的消费者在尝试订阅一个主题的时候都会被屏蔽,即使他们只在最初订阅一个主题,或者在出现断开时也是如此。这可能导致潜在的大量阻塞调用,从而耗尽有限的线程池数量。

有谁能给我一个启示,提供一个绕过这件事的方法吗?我正在使用Reactor-kafka库,ReactiveKafkaConsumerTemplate。

共有1个答案

皇甫飞跃
2023-03-14

Reactor kafka会在边线程上运行任何阻塞代码,以便不阻塞不应该阻塞的主事件循环(众所周知),并且在超时情况下,您可以设置ReceiverOptions,以便这些阻塞调用不会使其他线程饥饿。

这里是包装KafkaReceiver的KafkaReceiver实现,正如我所看到的,调度器在任何地方都被用来确保这一点。另外,这里是创建KafkaConsumer的地方,它是在runnable的run()方法中创建的。

 类似资料:
  • 问题内容: 和之间有什么区别?在文档中: 与 什么时候应该使用,什么时候应该使用? 问题答案: 用于描述其属性均为相同类型的对象。 用于描述对象的键事先已知的对象,并且可以表示不同的类型。

  • 我对状态同步有问题。当我点击编辑器的外部(想要关闭它),我想把实际的文本传回给父节点(函数)。但是当我在之外单击时,状态似乎总是落后一步。(例如:如果编辑器内部有,我键入,,我键入,等等)。 如果我在编辑器外单击,将出现的实际状态,如何实现这一点?

  • 我正在探索反应性Kafka,只是想确认反应性Kafka是否等同于同步制作人。与同步生产者,我们得到消息传递保证与确认字符和生产者序列保持。但是,ASYNC不能保证交付和测序。反应式生产者等同于SYNC还是ASYNC?

  • 问题内容: 使用react和electronic创建桌面应用程序。我想从react组件中调用main.js电子方法。 main.js 如何克服这个问题? 问题答案: 在您的Renderer.js 在您的main.js 这是在主进程与渲染进程之间进行通信的最简单方法。 但是我认为您将使用以下方法将主过程的结果发送到渲染器 因此,这意味着您正在通过IPC通道将结果从main发送到渲染器。并且您应该在渲

  • 有人能用一个真实的例子来帮助我理解React中的状态吗?

  • 问题内容: 在这里,我尝试设置为’hello’,然后打印它,但是状态似乎为空。当我刚刚使用更新状态时怎么办?设置为全局变量。 问题答案: 从reactjs文档中: 不会立即变异,但会创建待处理的状态转换。调用此方法后进行访问可能会返回现有值。 https://facebook.github.io/react/docs/component- api.html 您可以做的是将状态更新后传递给回调函数: