Docs Connect Components Processors avro avro Type: ProcessorScanner Available in: Cloud, Self-Managed Performs Avro based operations on messages based on a schema. # Config fields, showing default values label: "" avro: operator: "" # No default (required) encoding: textual schema: "" schema_path: "" 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. Fields operator The operator to execute Type: string 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: "" schema_path The path of a schema document to apply. Use either this or the schema field. Type: string Default: "" # Examples schema_path: file://path/to/spec.avsc schema_path: http://localhost:8081/path/to/spec/versions/1 Back to top × Simple online edits For simple changes, such as fixing a typo, you can edit the content directly on GitHub. Edit on GitHub Or, open an issue to let us know about something that you want us to change. Open an issue Contribution guide For extensive content updates, or if you prefer to work locally, read our contribution guide . Was this helpful? thumb_up thumb_down group Ask in the community mail Share your feedback group_add Make a contribution archive awk