addArray method

void addArray(
  1. Iterable items,
  2. KafkaType itemType
)

Adds Kafka array to this bytes builder.

Kafka array starts with int32 indicating size of the array followed by the array items encoded according to their KafkaType

Implementation

void addArray(Iterable items, KafkaType itemType) {
  addInt32(items.length);
  for (var item in items) {
    switch (itemType) {
      case KafkaType.int8:
        addInt8(item);
        break;
      case KafkaType.int16:
        addInt16(item);
        break;
      case KafkaType.int32:
        addInt32(item);
        break;
      case KafkaType.int64:
        addInt64(item);
        break;
      case KafkaType.string:
        addString(item);
        break;
      case KafkaType.bytes:
        addBytes(new List<int>.from(item));
        break;
      case KafkaType.object:
        throw new StateError('Objects are not supported yet');
    }
  }
}