Kafka 节点突然从偏移量 0 开始消耗
有时，kafka-node 消费者从偏移量 0 开始消费，而其默认行为仅消费较新的消息.然后它不会切换回其默认行为.你知道如何解决这个问题吗?会发生什么，它的行为会突然改变吗?代码非常简单，无需更改代码即可实现. var kafka = require("kafka-node") ;消费者 = kafka.Consumer;客户端 = 新 kafka.KafkaClient();消费者 = 新消
..
node-kafka相关内容
Kafka节点突然从偏移量0消耗
有时，kafka-node使用者从偏移量0开始消耗，而其默认行为是仅消耗较新的消息.然后，它将不会切换回其默认行为.您知道如何解决这个问题，会发生什么并且它的行为突然改变吗?代码非常简单，并且无需更改代码即可实现. var kafka = require("kafka-node") ; Consumer = kafka.Consumer; client = new kafka.Kaf
..
ProducerStream仅产生单个分区
我正在尝试向具有2个分区的单个主题生成一些消息.所有消息都将仅分配到2号分区. 我希望生产者流可以将消息分布在所有分区上. const kafka = require('kafka-node') const { Transform } = require('stream'); const _ = require('lodash'); const client = new kafka.Kaf
..