avro

Performs Avro based operations on messages based on a schema.

# Common config fields, showing default values
avro:
operator: to_json
encoding: textual
schema: ""

EXPERIMENTAL: This processor is considered experimental and is therefore subject to change outside of major version releases.

Operators

to_json

Converts Avro documents into a JSON structure. This makes it easier to manipulate the contents of the document within Benthos. The encoding field specifies how the source documents are encoded.

from_json

Attempts to convert JSON documents into Avro documents according to the specified encoding.

Fields

operator

The operator to execute

Type: string
Default: "to_json"
Options: to_json, from_json.

encoding

An Avro encoding format to use for conversions to and from a schema.

Type: string
Default: "textual"
Options: textual, binary, single.

schema

A full Avro schema to use.

Type: string
Default: ""

parts

An optional array of message indexes of a batch that the processor should apply to. If left empty all messages are processed. This field is only applicable when batching messages at the input level.

Indexes can be negative, and if so the part will be selected from the end counting backwards starting from -1.

Type: array
Default: []