我需要在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);