Struct JsonEncoderConfig

pub struct JsonEncoderConfig {
    pub update_format: JsonUpdateFormat,
    pub json_flavor: Option<JsonFlavor>,
    pub buffer_size_records: usize,
    pub array: bool,
    pub key_fields: Option<Vec<String>>,
}

Fields

update_format: JsonUpdateFormat

json_flavor: Option<JsonFlavor>

buffer_size_records: usize

array: bool

key_fields: Option<Vec<String>>

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

This option is useful when writing to a table with primary keys. For such tables, Debezium expects the message key to contain only the primary key columns.

This option is only valid with the debezium update format.

Trait Implementations

impl Default for JsonEncoderConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for JsonEncoderConfig

where JsonEncoderConfig: Default,

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for JsonEncoderConfig

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 JsonEncoderConfig

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.