-
KafkaJS生产者SSL证书
我正在用KafkaJS编写NodeJS Kafka生产者,并且在理解如何获取所需的SSL证书以使用SASL-SSL连接连接到Kafka时遇 -
如何暂停Nest.js Kafka使用者
我正在Nest.js项目中使用Kafka.js。 这就是我初始化KafkaClient的方式: <pre><code> @Module({ ... providers: [{ -
kafkajs-断开连接后优雅地停止kafkajs实例
我在生产和集成测试中都使用kafkajs。 在进行所有测试之前,我先使用生产者和消费者connect / subscr -
使用KafkaJS时的Kafka连接错误
我已根据以下说明在本地开发计算机上安装了Kafka: <a href="https://kafka.apache.org/documentation/#quickstart" rel="no -
如何在kafkajs中使自动提交错误工作
场景:<br/> 我将autocommit设置为false,<br/> 产生12条消息<br/> 正在消耗它们..(例如从偏移量100开始)<br/> -
测试Kafkajs主题和计数器(舞会客户端)
我正在开发一个打字稿应用程序,它使用来自特定Kafka主题的消息,并且基本上我必须验证该消息是否有 -
如何暂停KafkaJS使用者并在一段时间后重试
我正在使用KafkaJS(<a href="https://kafka.js.org" rel="nofollow noreferrer">https://kafka.js.org</a>)连接到Kafka集群。我 -
KafkaJS-查找偏移量最有效的方法
(涉及kafka和kafkajs的初学者完整,如果这是一个愚蠢的问题,我感到抱歉) 我遇到一个问题,我们 -
等待KafkaJS的领导层选举
<h2>情况</h2> 我正在使用<a href="https://kafka.js.org" rel="nofollow noreferrer">kafkajs</a>来写一些动态生成的kafka主题 -
创建KafkaJS中已经存在的主题可以吗?
<h1>情况</h1> 我正在使用<a href="https://kafka.js.org" rel="nofollow noreferrer">KafkaJS</a>动态创建一系列主题,<a href= -
NestJs EventBus在EventHandler处重复事件
我正在尝试使用Nestfs(使用Kafka作为事件存储)使用Event-Sourcing和CQRS。 该应用程序是一个小型且简 -
如何使消费者在Node.js中自动订阅动态创建的主题
关于stackoverflow本身有几个类似的问题,但我还是要再问一次,因为我想在<strong> NodeJS </strong>中找到解决 -
如何通过使用KafkaJS库从kafka主题的特定分区使用
我是kafka的新手,并在Node JS中实现了它。我已经使用kafka-js编写了一个使用者,并且想要从名为“ topic-A -
kafkajs消费者滞后,但消息已提交
需要有关kafkajs <strong>消费者滞后</strong> 的帮助 一个kubernetes Pod发送10条消息到queque kafdrop中的最后 -
无法使kafkajs同时读取消息
我正在尝试让kafkajs同时读取消息,<br/> 我正在用2个分区运行我的主题: <pre><code>Topic:Tokens_Activity_Sand -
KafkaJS:尝试产生有关主题的消息时,ECONNREFUSED
我正在使用KafkaJS生成有关Kafka主题的消息。 为此,我已使用<code>wurstmeister</code>映像将Kafka服务器放入Dock -
Kafkajs消耗和产生批次问题
我想在我的Node.js项目中使用kafkajs。让我展示我的代码。 制作人: <pre class="lang-js prettyprint-overri -
Kafka Producer:发送消息后断开连接与保持连接打开
我无法在 <a href="https://kafka.js.org/docs/producing" rel="nofollow noreferrer">kafkajs docs</a> 或浏览官方 Apache Kafka <a hre -
如何在 Kubernetes 上的 Node.js 中扩展 kafka 消费者
有一些设计问题,希望根据您使用 Kafka 和 <strong>KafkaJS</strong>(任何此类库)的经验提供反馈: <ol> <l -
如何在使用 KafkaJS 的 Jest 测试中等待 Kafka 响应?
考虑这个测试,其中一条消息从测试发送到主题“out”,被测试的代码预计会消费它并通过向主题“in” -
消费者有没有办法向使用 kafka(kafka.js) 和 node.js 实现的生产者发送确认?
我相信 3 种类型的确认,因为生产者属性仅限于领导者和生产者,我希望生产者在消费者通过 kafka 代理 -
Nest.js 将 kafka 客户端注入到服务中
我有一个 Nest.js 微服务应用程序。对于 MS 之间的消息代理,我使用的是 kafka。 现在我想在健康服 -
如何将 Kafkajs 与 Socket.io 连接
我一直在研究 kafkajs 和 socket.io 我对它很陌生,我似乎无法理解一些东西。 我创建了一个聊天应用程序 -
Kafka js容器无法连接到同一个docker堆栈上的kafka容器
我有一个 ELKK docker compose 堆栈,我正在尝试将 kafka 客户端(kafka js)连接到 kafka,但没有成功。 <st -
kafkajs dns 缓存zookeper
我有一个用 kafkajs 编写的生产者,它连接到 Kafka 集群。代理 urls = 一个 DNS URL,它为我提供了其中一个 ka -
如何使用 NestJS KafkaClient 订阅 Kafka 主题?
我正在使用 <a href="https://docs.nestjs.com/websockets/adapter" rel="nofollow noreferrer">NestJS adapters</a> 实现 kafka 适配器 -
如何在 JS 中为 Kafka 消费者获取分配的分区
我正在使用 KAFKAJS 与 Kafka 消费者合作。 我需要知道分配给特定使用者的所有分区。 例如,假设主 -
Nestjs kafka 实现
我已经阅读了 nestjs 微服务和 kafka 文档,但我无法弄清楚其中的一些。如果你能帮助我,我将不胜感激 -
Kafka js 快速示例错误
我有这个非常简单的代码,它应该只是使用来自 <a href="https://github.com/tulios/kafkajs" rel="nofollow noreferrer">the -
如何有多个 Kafka 代理复制
所以我是 kafka 的新手,我很难找到有关拥有多个 kafka 实例的信息,以便在代理实例出现故障时仍然保持