xk6-avro

This extension wraps the goavro library into a k6 extension.

You can build the extension using:

xk6 build --with github.com/xvzf/xk6-avro

Example

import avro from "k6/x/avro"

const codec = avro.NewCodec(`{
  "type": "record",
  "name": "LongList",
  "fields" : [
    {"name": "next", "type": ["null", "LongList"], "default": null}
  ]
}`)
let binary = codec.binaryFromTextual(`{"next":{"LongList":{}}}`)
console.log(binary)

let textual = codec.textualFromBinary(binary)
console.log(textual)

// When actually doing an HTTP request using the k6 http client, data has to be passed as ArrayBuffer:
const binaryAB = new Uint8Array(binary).buffer
http.post(`https://example.com/avro-receiver`, binaryAB, {headers: {"Content-Type": "binary/avro"}})