Connect
Also in Cloud

avro

Performs Avro based operations on messages based on a schema.

If you are consuming or generating messages using a schema registry service then it is likely this processor will fail as those services require messages to be prefixed with the identifier of the schema version being used. Instead, try the schema_registry_encode and schema_registry_decode processors.

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.

  • Common

  • Advanced

processor:
  label: ""
  avro:
    operator: "" # No default (required)
    encoding: textual
    schema: ""
    schema_path: ""
processor:
  label: ""
  avro:
    operator: "" # No default (required)
    encoding: textual
    schema: ""
    schema_path: ""

Fields

encoding

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

Type: string

Default: textual

Options: textual, binary, single

operator

The operator to execute

Type: string

Options: to_json, from_json

schema

A full Avro schema to use.

Type: string

Default: ""

schema_path

The path of a schema document to apply. Use either this or the schema field. URLs must begin with file:// or http://. Note that file:// URLs must use absolute paths (for example, file:///absolute/path/to/spec.avsc); relative paths are not supported.

Type: string

Default: ""

# Examples:
schema_path: file:///path/to/spec.avsc

# ---

schema_path: http://localhost:8081/path/to/spec/versions/1