Builtin Processors

📄️ avro.decode

Decodes a field's raw data in the Avro format.

Encodes a record's field into the Avro format.

Decode a field to base64.

Encode a field to base64.

Conduit processor for Cohere's command model.

Conduit processor for Cohere's embed model.

Conduit processor for Cohere's rerank model.

Run custom JavaScript code.

Returns an error for all records that get passed to the processor.

Convert the type of a field.

Remove a subset of fields from the record.

Rename a group of fields.

Set the value of a certain field.

Acknowledges all records that get passed to the filter.

Decodes a specific field from JSON raw data (string) to structured data.

Encodes a specific field from structured data to JSON raw data (string).

Processes data through an Ollama instance

Generate embeddings for records using OpenAI models.

modify records using openai models

Unwraps a Debezium record from the input OpenCDC record.

Unwraps a Kafka Connect record from an OpenCDC record.

Unwraps an OpenCDC record saved in one of the record's fields.

Trigger an HTTP request for every record.

scarf pixel conduit-site-docs-using-processors