Tag: kafka producer api

Node.js kafka节点分区程序types的用法

我试图通过节点js使用kafka-node将数据插入到kafka主题中。 如果我尝试使用partitionerType，数据不会被插入。 如果我删除PartitionerType（即不使用选项），代码的作品，但在这种情况下，所有的数据只有一个分区。 你能帮我解决这个问题吗？ 提前致谢。 var kafka = require('kafka-node'), Producer = kafka.Producer, KeyedMessage = kafka.KeyedMessage, client = new kafka.Client("zookeeper-host:2181","node-id"), options = { requireAcks: 1, ackTimeoutMs: 100, partitionerType: 3 }, producer = new Producer(client, options); //producer = new Producer(client); — This works var km = new KeyedMessage('key1', 'message6'), kn = new KeyedMessage('key2', 'message5'), kv = new […]

kafka错误：请求偏移量X，但是我们只有从Y到Z范围内的日志段

我有工作kafka实例，但现在它产生成千上万的错误，如下所示： [2016-06-24 01：33：28,092] ERROR [代理0上的副本pipe理器]：在处理来自消费者的分区[test-topic，0]偏移45的提取请求时出错，相关标识为85452.可能的原因： 45，但我们只有0到0范围内的日志段。（kafka.server.ReplicaManager） 我正在使用默认configuration。 我在node.js代码中使用了几个主题。 UPD：重新安装卡夫卡帮助我，但我想知道问题的原始来源。