1
Can u bitte die kafkaClient mit NodeJS mit über Port 9092 nicht Zookeeper Port 2181.KafkaClient mit NodeJS
var kafka = require('kafka-node'),
Producer = kafka.Producer,
KeyedMessage = kafka.KeyedMessage,
client = new kafka.Client(),
producer = new Producer(client),
km = new KeyedMessage('key', 'message'),
payloads = [
{ topic: 'topic1', messages: 'hi', partition: 0 },
{ topic: 'topic2', messages: ['hello', 'world', km] }
];
producer.on('ready', function() {
producer.send(payloads, function (err, data) {
console.log(data);
});
});
producer.on('error', function (err) {})
Können Sie mir bitte den Modulnamen oder einen beliebigen Beispielcode mitteilen. –
Ich verwende den Blizzard/node-rdkafka-Client (siehe https://github.com/Blizzard/node-rdkafka), der einige Beispiele enthält. Ich schrieb auch einen Beispielkonsolenhersteller und -verbraucher hier https://github.com/hjespers/ccloud-node-console-client. Dies funktioniert ohne Tierpfleger. –