toBytes method

@override List<int> toBytes()

Implementation

@override
List<int> toBytes() {
  var builder = new KafkaBytesBuilder.withRequestHeader(apiKey, apiVersion, correlationId);

  builder.addInt32(_replicaId);
  builder.addInt32(maxWaitTime);
  builder.addInt32(minBytes);

  builder.addInt32(_topics.length);
  _topics.forEach((topicName, partitions) {
    builder.addString(topicName);
    builder.addInt32(partitions.length);
    partitions.forEach((p) {
      builder.addInt32(p.partitionId);
      builder.addInt64(p.fetchOffset);
      builder.addInt32(p.maxBytes);
    });
  });

  var body = builder.takeBytes();
  builder.addBytes(body);

  return builder.takeBytes();
}