node.js - 无法连接到 gcp 上的 kafka 主机

Question

我正在尝试使用 nodejs 从 GCP 上的某个主题中获取消息，但我没有看到任何输出。

生产者和消费者在实例上正常运行。我正在尝试使用以下命令：
生产者：

kafka-console-producer.sh --broker-list XXXX:9092 --producer.c onfig /opt/bitnami/kafka/conf/producer.properties --topic test

消费者 ：

/opt/bitnami/kafka/bin/kafka-console-consumer.sh --bootstrap-server XXXX:9092 --top ic test --consumer.config /opt/bitnami/kafka/conf/consumer.properties --from-开始

现在，我尝试使用以下 nodejs 代码来使用这些消息。

var kafka = require('kafka-node'),
    Consumer = kafka.Consumer,
    client = new kafka.KafkaClient({kafkaHost: 'X.X.X.X:9092', connectTimeout: 3000, requestTimeout:3000}),
    consumer = new Consumer(client,
        [{ topic: 'Posts', offset: 0}],
        {
            autoCommit: false
        }
    );

consumer.on('message', function (message) {
    console.log(message);
});

consumer.on('error', function (err) {
    console.log('Error:',err);
})

consumer.on('offsetOutOfRange', function (err) {
    console.log('offsetOutOfRange:',err);
})

我应该看到生产者产生的消息作为输出。

标签： node.jsgoogle-cloud-platformapache-kafka