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); 
});

确保IP和端口是正确的。另外检查你是否真的可以联系到经纪人机器（你可以ping通吗？）。还要确保您的经纪人版本与您的客户端版本兼容 - 经纪人必须拥有相同版本的必须更新（即更高版本）。同时检查代理日志以查找错误消息。 –

您的连接IP应该指向kafka的动物园管理员实例，而不是kafka经纪人。 – Xiaoxin

答

所以，出于某种原因，这个问题是在节点卡夫卡，卡夫卡节点和卡夫卡式的问题，我不知道如何解决。

no-kafka可以很好的与外界沟通。

Kafka节点连接到kafka的本地主机实例，但没有连接到远程kafka服务器

相关推荐