MetadataResponse.fromBytes constructor

MetadataResponse.fromBytes(
  1. List<int> data
)

Creates response from binary data.

Implementation

factory MetadataResponse.fromBytes(List<int> data) {
  var reader = new KafkaBytesReader.fromBytes(data);
  var size = reader.readInt32();
  assert(size == data.length - 4);

  reader.readInt32(); // correlationId

  var brokers = reader.readArray(KafkaType.object, (reader) {
    return new Broker(reader.readInt32(), reader.readString(), reader.readInt32());
  });

  var topicMetadata = reader.readArray(KafkaType.object, (reader) => new TopicMetadata._readFrom(reader));
  return new MetadataResponse._(new List<Broker>.from(brokers), new List<TopicMetadata>.from(topicMetadata));
}