Kafka節點連接到kafka的本地主機實例，但沒有連接到遠程kafka服務器

我目前使用的是驅動程序kafka-node，並且這工作正常，我確實從當前在本地運行時消耗的消息和隊列中獲得輸出但是當我嘗試連接到外部kafka機器。任何人都可以幫忙嗎？Kafka節點連接到kafka的本地主機實例，但沒有連接到遠程kafka服務器

當我這樣做時，我沒有收到錯誤，代碼只是掛在終端上而沒有返回任何東西。 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); 
});

來源

2016-11-11 Heimdallr NF

確保IP和端口是正確的。另外檢查你是否真的可以聯繫到經紀人機器（你可以ping通嗎？）。還要確保您的經紀人版本與您的客戶端版本兼容 - 經紀人必須擁有相同版本的必須更新（即更高版本）。同時檢查代理日誌以查找錯誤消息。 –

您的連接IP應該指向kafka的動物園管理員實例，而不是kafka經紀人。 – Xiaoxin