Узел kafka-consumer не потребляет сообщения после перезапуска kafka - PullRequest
Новая
       59

Узел kafka-consumer не потребляет сообщения после перезапуска kafka

0 голосов
/ 09 января 2020

У меня есть nodejs код с kafka (npm kafka-node), потребитель. js не будет потреблять никаких сообщений при перезапуске kafka-сервера. Но, к сожалению, это работает, если я перезапускаю потребитель. js файл.
Может ли кто-нибудь мне помочь ..?
заранее спасибо.

consumer.js

var kafka = require('kafka-node'),
    Producer = kafka.Producer,
    KeyedMessage = kafka.KeyedMessage,
    kclient = new kafka.KafkaClient(),
    producer = new Producer(kclient),
    Consumer = kafka.Consumer,
    consumer = new Consumer(
        kclient,
        [
            { topic: 'acceptmessages'}
        ],
        {
            fromOffset: false,
            autoCommit: true
        }
    );


consumer.on('message', function (message) {
    console.log("message from consumer "+message.value);
})
...