Struct AvroParserConfig

pub struct AvroParserConfig {
    pub update_format: AvroUpdateFormat,
    pub schema: Option<String>,
    pub skip_schema_id: bool,
    pub registry_config: AvroSchemaRegistryConfig,
}

Avro output format configuration.

Fields

update_format: AvroUpdateFormat

Format used to encode data change events in this stream.

The default value is ‘raw’.

schema: Option<String>

Avro schema used to encode all records in this stream, specified as a JSON-encoded string.

When this property is set, the connector uses the provided schema instead of retrieving the schema from the schema registry. This setting is mutually exclusive with registry_urls.

skip_schema_id: bool

true if serialized messages only contain raw data without the header carrying schema ID.

See https://docs.confluent.io/platform/current/schema-registry/fundamentals/serdes-develop/index.html#wire-format

The default value is false.

registry_config: AvroSchemaRegistryConfig

Schema registry configuration.

Trait Implementations

impl Clone for AvroParserConfig

fn clone(&self) -> AvroParserConfig

Returns a duplicate of the value.

const fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for AvroParserConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for AvroParserConfig

fn default() -> AvroParserConfig

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for AvroParserConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for AvroParserConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl<'__s> ToSchema<'__s> for AvroParserConfig

fn schema() -> (&'__s str, RefOr<Schema>)

Return a tuple of name and schema or reference to a schema that can be referenced by the name or inlined directly to responses, request bodies or parameters.

fn aliases() -> Vec<(&'__s str, Schema)>

Optional set of alias schemas for the ToSchema::schema.