カフカノードがkafkaのlocalhostインスタンスに接続していますが、リモートカフカサーバに接続していません

Question

私は現在ドライバkafka-nodeを使用していますが、これは問題なく動作しています。しかし、私は外部のカフカマシンに接続しようとします。 誰もがこれを助けることができますか？

これを行うと、エラーは発生しません。コードは端末に何も返さずにハングするだけです。 ctrl + cは私を殺すのに役立ちます。

下記のコードをご覧ください。 おかげ

私はこれを行う

が、私はいくつかの理由ではない

var kafka = require('kafka-node'), 
    Consumer = kafka.Consumer, 
    client = new kafka.Client('SOMEIP_ADRESS:9092'), 
// client = new kafka.Client('localhost:2181'), 
    consumer = new Consumer(
     client, 
     [ 
       { topic: 'catTopic', partition: 0 } 
      //{ topic: 'dogTopic', partition: 0 } 
     ], 
     { 
      autoCommit: false, 
      fromBeginning: true 

     } 
    ); 
// how de we get the messages on the queue 


// we only ac when we get messages 
consumer.on('message', function (message) { 
    console.log(message); 
}); 

Answer 1

そう、この問題は私が解決するか見当がつかないノード・カフカ、カフカ・ノードとkafkaesque問題です。

ノーカフカは外界とうまく動作します。