1回答
有时，kafka-node消费者从偏移量0开始消费，而它的默认行为是只消费较新的消息。则它将不会切换回其默认行为。你知道如何解决这个问题吗?知道发生了什么，它的行为突然改变了吗？var kafka = require("kafka-node") ; client = new kafka.KafkaClient();;
consumer.on("message", f
浏览 5提问于2020-01-31得票数 3
我正在尝试为节点中的应用程序设置Kafka队列。我在消费者组中有3个消费者，并且订阅了单个主题，但是当生产者向具有3个分区的主题发送消息时，接收重复消息的消费者组从partition1读取并获取消息，而consumer2也从相同的分区读取并获取相同的消息用于创建消费者组的选项如下所示 consumerO
浏览 10提问于2019-09-03得票数 2
我尝试通过kafka-node npm库使用consumer和producer，以便通过nodejs使用kafka作为消息服务。问题是，尽管我的生产者有时会工作，但消费者总是给我超时错误，或者它只是在无休止的循环中尝试连接到kafka，即使tought也工作得很好。当Kafka在远程centos7机器上时，我在windows机器上使用kafka-node。我试着在kafka内置的生
浏览 56提问于2019-06-19得票数 3
我在NodeJS应用程序中使用Kafka-Node来产生和使用消息。我启动了一个等待我的主题的消费者。然后启动producer并将消息发送给Kafka。我的客户正在将这些消息中的每一条都插入Postgres数据库。当我停止消费者并继续生产时，我在大约30秒后重新启动消费者。我注意到大约有十几条消息已经从原始消费者</em
浏览 21提问于2019-07-11得票数 1
我在Kafka NodeJS中使用了一个简单的消费者/生产者。我的生产者正在发送消息，我很容易在消费者中获得这些消息。生产者和消费者的代码如下。在消费者中，我期望offset.fetch()给我今天的所有偏移量it，但它没有。KIndly指导我如何从这个方法中获得结果，并且还提到了一个方法，它可以直接给出任何分区主题中的最后一个偏移量。我还想知道如何过滤
浏览 1提问于2015-07-29得票数 3
1回答
所以我从我的kafka用户那里得到了一些恼人的补偿提交案例。我在我的项目中使用'kafka-node‘。我创建了一个主题。在超过2台服务器的消费者组中创建了2个消费者。自动提交设置为false。对于我的消费者得到的每个消息，他们开始一个异步进程，这可能需要1到20秒，当进程完成时，消费者提交偏移量。我的问题是:有一个传感器，消费者1收到一条消息，需要20
浏览 2提问于2019-05-17得票数 0
似乎我的卡夫卡节点消费者：var consumer = new Consumer(client, [], {在某些情况下我处理不了太多的消息。是否有办法限制它(例如，每秒接受不超过1000条消息，可能使用暂停api)？
我使用的是kafka节点，与Java版本相比，它似乎有一个有限的api。
浏览 14提问于2016-07-23得票数 6
我创建了一个生产者和一个消费者，使用“Kafka节点”包发送和消费来自kafka主题的信息。生产者和消费者通过API调用。POST方法用于向主题发送消息，而GET方法用于在使用者处从主题获取消息。当我在向KAFKA发送消息之后调用消费API时，所有以前的消息都在consumer.on('message', function(message){})中</e
浏览 6提问于2021-12-15得票数 0
1回答
我在活动上用“kafka -node”创建了kafka消费者。.MongoClient, assert = require('assert');
console.log('message' + database)
浏览 0提问于2019-04-03得票数 0
回答已采纳
我跟随在Ubuntu14.04服务器上安装了Kafka。为生产者和消费者提供的示例运行良好。下面是生产者命令：下面是消费者的命令：
~/kafka</
浏览 2提问于2016-06-08得票数 2
回答已采纳
因此，我刚刚开始探索kafka (使用节点js)，并且使用kafka节点模块与kafka交互。我刚刚编写了一些测试消费者代码(见下文)。当我运行这个使用者代码的多个实例并将新消息推送到一个主题时，所有使用
浏览 0提问于2017-06-10得票数 0
回答已采纳
我有一个主题，我必须从kafka服务器读取，所以我只需要创建消费者，可以从kafka主题读取数据，我总是得到错误主题不存在。main.jsvar config = require('./config.js');
var kafkaCon
浏览 3提问于2016-06-21得票数 2
回答已采纳
1回答
我正在使用快捷和卡夫卡节点构建一个简单的node.js API，在收到请求时返回来自请求的主题和使用者组的未读消息，然后关闭连接。我不需要也不希望消费者继续等待新的信息。在kafka节点中，检查主题是否已经结束，如果是，关闭与代理的连接并退出应用程序，以防止新消息被读取的正确方法是什么？
const k
浏览 1提问于2019-05-29得票数 0
回答已采纳
3回答
我首先会说，如果这个问题看起来很普通，我很抱歉，但我在解决这个问题上遇到了麻烦。所以我在这里试一试。我想用react构建一个kafka主题的消费者，这样每当我的主题中有新的消息时，它就会呈现出我不知道的东西，比如网格。我已经有了消费者的代码：Consumer = kafka.Consumer,
client = new kafka.Client
浏览 1提问于2015-09-15得票数 10
回答已采纳
我第一次在kafka中使用Node，使用的是kafka-node。消费消息需要调用外部API，这甚至可能需要一秒钟的响应时间。我希望克服我的消费者的突然故障，如果一个消费者发生故障，将取代它的另一个消费者将收到相同的消息，即其工作尚未完成。
我正在使用kafka 0.10，并尝试使用ConsumerGroup。我考虑在options中设置autoCommit: false，并仅在消息</em
浏览 0提问于2016-10-18得票数 4
6回答
即时通信使用kafka-node 模块你知道我如何向服务器声明我消费了一条消息，而在我重启consumer时他不再发送给我吗生产者代码var HighLevelProducer = kafka.HighLevelProducer;
var Client= require('ka
浏览 15提问于2014-11-04得票数 5
从名称上看，它意味着它与消费者偏移量有关，但它是如何使用的呢？$ bin/kafka-topics.sh --list --zookeeper localhost:2181 __consumer_offsets test这发生在Kafka1.1.0中，以及为什么有50个
浏览 5提问于2018-12-13得票数 3
1回答
我正在使用kafka节点模块向kafka发送消息。在集群环境中，我有一个主题，其中有3个分区，复制因子为3。当我遵循下面的步骤
kafka:9093send 获取连接到kafka:9092的HighLevelProducer实例，a message 停止kafka-server:9092手动，然后用HighLevelProducer发送另一条消息，并发送()将触发回调，错误为: TimeoutError:请求超时后3
浏览 3提问于2019-09-23得票数 1
1回答
有没有办法让kafka在一个消费者身上拥有多个主题？这是我的消费者代码，它可以很好地处理单个主题 let consumer = new Consumer( [{ topic: '1234', offset:); console.log(
'kafka
浏览 36提问于2019-06-26得票数 1
回答已采纳
我正在尝试使用kafka-node来读取来自kafka主题的压缩消息。kafka-topics.sh --zookeeper ${KAFKA_HOST}:2181 --create --topic atopic --config
浏览 2提问于2018-08-25得票数 0
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
