consumer.js

consumer
  .on('ready', () => {
    consumer.subscribe([topic]);
    consumer.getMetadata({topic: topic}, function (err, metadata) {
      if (err) {
        console.error('Error getting metadata');
        console.error(err);
      } else {
        console.log('Got metadata');
        console.log(metadata.topics[1]);
        var partitions = metadata.topics[1].partitions;
        partitions.map((p) => {
          consumer.queryWatermarkOffsets(topic, p.id, (err, offsets) => {
            console.log(offsets);
            consumer.seek({topic: topic, partition: p.id, offset: offsets.lowOffset}, 1000, function (err) {
              if (err) {
                console.log(err);
              }
            });
          });
        });
        setTimeout(function () {
          consumer.consume();
        }, 5000)
      }
    });

  })
  .on('data', (data) => {
  console.log(data);
};);