kafka-split

Transform stream for splitting up kafka messages

Install

$ npm install kafka-split

Usage

'use strict'

const Split = require('kafka-split')
const net = require('net')

const socket = net.connect()
socket.pipe(Split()).on('data', (chunk) => {
  // chunk will be a kafka buffer that represents a full kafka message
  // starting with the size
})

Test

$ npm test

Author

Evan Lucas

License

MIT (See LICENSE for more info)