toBytes method

  1. @override
List<int> toBytes()
override

Implementation

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

  builder.addString(consumerGroup);
  builder.addInt32(topics.length);
  topics.forEach((topicName, partitions) {
    builder.addString(topicName);
    builder.addArray(partitions, KafkaType.int32);
  });

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

  return builder.takeBytes();
}