toBytes method

List<int> toBytes()

Converts this MessageSet into sequence of bytes according to Kafka protocol.

Implementation

List<int> toBytes() {
  var builder = new KafkaBytesBuilder();
  _messages.forEach((offset, message) {
    var messageData = _messageToBytes(message);
    builder.addInt64(offset);
    builder.addInt32(messageData.length);
    builder.addRaw(messageData);
  });

  return builder.toBytes();
}