我正在尝试使用nodejs使用gcp上的某个主题中的消息，但没有看到任何输出。
生产者和消费者在示例上使用正确运行。我尝试使用以下命令：
制作人：
kafka-console-producer.sh--代理列表x.x.x.x:9092--producer.c onfig/opt/bitnami/kafka/conf/producer.properties--主题测试
消费者：
/opt/bitnami/kafka/bin/kafka-console-consumer.sh--引导服务器x.x.x.x:9092--顶级ic测试--consumer.config/opt/bitnami/kafka/conf/consumer.properties--从头开始
现在，我尝试使用下面的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);
})

我应该将生产者生成的消息视为输出。