OffsetFetchResponse.fromData constructor

OffsetFetchResponse.fromData(List<int> data)

Implementation

factory OffsetFetchResponse.fromData(List<int> data) {
  List<ConsumerOffset> offsets = [];
  var reader = new KafkaBytesReader.fromBytes(data);
  var size = reader.readInt32();
  assert(size == data.length - 4);

  reader.readInt32(); // correlationId
  var count = reader.readInt32();
  while (count > 0) {
    var topicName = reader.readString();
    var partitionCount = reader.readInt32();
    while (partitionCount > 0) {
      var id = reader.readInt32();
      var offset = reader.readInt64();
      var metadata = reader.readString();
      var errorCode = reader.readInt16();
      offsets.add(new ConsumerOffset(topicName, id, offset, metadata, errorCode));
      partitionCount--;
    }
    count--;
  }

  return new OffsetFetchResponse._(offsets);
}