Struct AvroEncoderConfig

pub struct AvroEncoderConfig {
    pub update_format: AvroUpdateFormat,
    pub schema: Option<String>,
    pub namespace: Option<String>,
    pub subject_name_strategy: Option<SubjectNameStrategy>,
    pub key_fields: Option<Vec<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 output records.

When specified, the encoder will use this schema; otherwise it will automatically generate an Avro schema based on the SQL view definition.

Specified as a string containing schema definition in JSON format. This schema must match precisely the SQL view definition, modulo nullability of columns.

namespace: Option<String>

Avro namespace for the generated Avro schemas.

subject_name_strategy: Option<SubjectNameStrategy>

Subject name strategy used to publish Avro schemas used by the connector in the schema registry.

When this property is not specified, the connector chooses subject name strategy automatically:

• topic_name for confluent_jdbc update format
• record_name for raw update format

key_fields: Option<Vec<String>>

When this option is set, only the listed fields appear in the Debezium message key.

This option is only valid with the confluent_jdbc update format. It is used when writing to a table with primary keys. For such tables, the Confluent JDBC sink connector expects the message key (and its schema) to contain only the primary key columns.

When this field is set, the connector generates a separate Avro schema, containing only the listed fields, and uses this schema to encode Kafka message keys.

skip_schema_id: bool

Set to true if serialized messages should only contain raw data without the header carrying schema ID. False by default.

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

registry_config: AvroSchemaRegistryConfig

Schema registry configuration.

When configured, the connector will push the Avro schema, whether it is specified as part of connector configuration or generated automatically, to the schema registry and use the schema id assigned by the registry in the

Trait Implementations

impl Debug for AvroEncoderConfig

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

Formats the value using the given formatter.

impl Default for AvroEncoderConfig

fn default() -> AvroEncoderConfig

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for AvroEncoderConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for AvroEncoderConfig

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 AvroEncoderConfig

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.