toBytes method

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

Implementation

@override
List<int> toBytes() {
  var builder = KafkaBytesBuilder.withRequestHeader(apiKey, apiVersion, correlationId);
  Set<String> list = (this.topicNames is Set) ? this.topicNames! : Set();
  builder.addArray(list, KafkaType.string);

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

  return builder.takeBytes();
}