Блог

Я пытаюсь использовать сообщения из темы на GCP, используя nodejs, но я не вижу никаких результатов.

Производитель и потребитель работают правильно, используя экземпляр. Я пытаюсь это сделать, используя следующие команды:
Producer:

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 —bootstrap-сервер X.X.X.X:9092 —top ic test —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);
})
 

Я должен видеть сообщения, созданные производителем в качестве выходных данных.