2017-07-10 3 views
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) {}) 

Antwort

0

Neuere Kafka Kunden nicht mehr erklären müssen direkt mit zookeeper sprechen. Sie müssen nur mit Kafka sprechen.

+0

Können Sie mir bitte den Modulnamen oder einen beliebigen Beispielcode mitteilen. –

+0

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. –