Как транслировать видео из node.js в kafka с потоком kafka?

Question

Мне нужно реализовать потоковое видео с помощью kafka. Я могу транслировать видео в браузер с помощью node.js. Но я хочу знать, как транслировать видео с node.js на производителя kafka.а также потребитель.

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

const Transform = require('stream').Transform;
const ProducerStream = require('./lib/producerStream');
const _ = require('lodash');
const producer = new ProducerStream();
const stdinTransform = new Transform({
    objectMode: true,
    decodeStrings: true,
    transform (text, encoding, callback) {
        text = _.trim(text);
        console.log(`pushing message ${text} to ExampleTopic`);
        callback(null, {
            topic: 'ExampleTopic',
            messages: text
        });
    }
});
process.stdin.setEncoding('utf8');
process.stdin.pipe(stdinTransform).pipe(producer);