// scale beyond a single node
const broker = new KafkaBroker({
topic: 'media.events',
partitions: 12,
})
await broker.publish(chunk)
// peer signaling over websockets
socket.on('offer', async (sdp) => {
const answer = await pc.createAnswer()
await pc.setLocalDescription(answer)
})
export default broker
// scale beyond a single node
const broker = new KafkaBroker({
topic: 'media.events',
partitions: 12,
})
await broker.publish(chunk)
// peer signaling over websockets
socket.on('offer', async (sdp) => {
const answer = await pc.createAnswer()
await pc.setLocalDescription(answer)
})
export default broker