回答情况：
提问时间：
问题标签：
我在生产测试和集成测试中都使用kafkajs。在进行所有测试之前，我将使用生产者&消费者连接/订阅/运行(EachMeassage)创建一个kafkajs实例.经过所有的测试，我想优雅地停止所有节点进程，包括kafkajs组件。是否有一种方法可以优雅地销毁节点进程中的kafkajs实例？
浏览 5提问于2020-03-31得票数 2
回答已采纳
我正在用NodeJS编写一个使用KafkaJS的KafkaJS卡夫卡生产者，并且很难理解如何获得所需的SSL证书，以便使用SASL连接连接到Kafka。在KafkaJS文档中，对SSL的配置如下： rejectUnauthorized: false,
ca: [fs.readFileSync('/my/custom/ca.crt我们已经配置了Kafka集群，所以，我是否必须解码keystore或其他东西，以便为我的KafkaJS生产者获得正确的证书？我对
浏览 2提问于2019-11-05得票数 1
我正在尝试使用kafkajs来创建一个kafka消费者。broker, trying another broker from the list: Closed connection"const { Kafka } = require('kafkajs
浏览 114提问于2019-10-31得票数 3
回答已采纳
这是我使用kafkajs的制作人。当我在options.username中提供了不正确的用户名时，我看到消息Connected。如何使用kafkajs处理连接错误 const { Kafka, logLevel } = require('kafkajs')
async function kafkaProducer(options
浏览 50修改于2020-05-04得票数 0
offset、batchContext.firstOffset、batchContext.firstTimestamp、batchContext.maxTimestamp)有没有办法记录lag值和kafkajs
浏览 1修改于2021-08-13得票数 2
我正在编写一个使用Node和kafkajs 实现2个消费者的服务const { Kafka } = require('kafkajs')
const kafka = new
浏览 6提问于2022-02-08得票数 1
在KafkaJS中，什么是等价的？import { Kafka, logLevel } from 'kafkajs';
clientId: 'qa-topic
浏览 16提问于2022-04-14得票数 1
我试图使用kafkajs从Kafka获取消息，我想将所有消息捕获到" messages“(一个数组) config中--在这里保存信任的变量是我使用的函数：async function consume_messages(config) {
const kafka = new Kafka({
浏览 7修改于2022-09-11得票数 0
完全错误是：
{"level":"ERROR","timestamp":"2020-08-24T17:48:40.201Z","logger":"kafkajs","message":"[Connection
浏览 3提问于2020-08-24得票数 7
回答已采纳
我正在用NodeJS用kafkaJS库写一个卡夫卡制作人。const { Kafka } = require('kafkajs')
clientId: 'my-app
浏览 2提问于2019-01-09得票数 0
回答已采纳
我计划使用Kafkajs 并在NodeJs服务器中实现它。我想知道，如果我有2个(或更多)服务器运行实例，其中每个实例的使用者都配置了相同的组id和主题，那么预期的行为是什么？我读过这个- ，但不确定它是否适用于Kafkajs
浏览 5提问于2022-02-10得票数 0
回答已采纳
我正在使用KafkaJS生成一条关于卡夫卡主题的消息。为此，我使用wurstmeister镜像将Kafka服务器放在Docker中。但我在尝试生成消息时出现错误 错误：poll | {"level":"ERROR","timestamp":"2020-10-24T15:21:27.113Z","logger":"kafkajs","
浏览 61修改于2020-10-25得票数 2
回答已采纳
我正在使用kafkajs库来实现nodejs中的kafka使用者。我试图在kafkajs的官方文档中找到参数，在那里我可以指定消费者群体中需要的消费者数量，但是我找不到。在kafkajs消费者实例中是否有传递消费者数量的方法？有参数partitionsConsumedConcurrently，但它实际上并不创建使用者。
浏览 19修改于2022-09-29得票数 0
回答已采纳
我在nodejs中有一个简单的应用程序，我正在尝试在KafkaJS中创建一个事务。我跟踪了，并使用一个事务id连接了我的客户端，并创建了一个事务性生产者。KafkaJSError: The producer is disconnected
at validateConnectionStatus (/usr/local/apps/app/node_modules/kafkajs
浏览 29修改于2022-07-01得票数 0
回答已采纳
},
现在，如果连接到代理有问题，它会抛出如下错误：{"level":"ERROR","timestamp":&q
浏览 21提问于2022-10-21得票数 1
2.15.8 我正在运行以下代码，它是从以下URL复制而来的 https://kafka.js.org/docs/getting-started const { Kafka } = require('kafkajs除此之外，我还安装了以下软件 npm install kafkajs 当我运行app.js文件时，我得到以下错误 /Users/nick/Documents/nodeprojects/simpleapp/apps.j
浏览 21提问于2019-10-04得票数 0
(说到卡夫卡和卡夫卡哈，完全是初学者，所以如果这是个愚蠢的问题，我很抱歉)本主题中的每一条消息都是JSON，并且在UNIX毫秒内有一个时间戳，从epoch (UTC)开始。
浏览 4提问于2020-07-27得票数 1
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号