Struct DebeziumJsonFormatter

pub struct DebeziumJsonFormatter {
    schema: Schema,
    pk_indices: Vec<usize>,
    db_name: String,
    sink_from_name: String,
    opts: DebeziumAdapterOpts,
    key_encoder: JsonEncoder,
    val_encoder: JsonEncoder,
}

Fields

schema: Schema

pk_indices: Vec<usize>

db_name: String

sink_from_name: String

opts: DebeziumAdapterOpts

key_encoder: JsonEncoder

val_encoder: JsonEncoder

Implementations

impl DebeziumJsonFormatter

pub fn new( schema: Schema, pk_indices: Vec<usize>, db_name: String, sink_from_name: String, opts: DebeziumAdapterOpts, ) -> Self

Trait Implementations

impl FormatterBuild for DebeziumJsonFormatter

async fn build(b: FormatterParams<'_>) -> Result<Self>

impl SinkFormatter for DebeziumJsonFormatter

type K = Value

type V = Value

fn format_chunk( &self, chunk: &StreamChunk, ) -> impl Iterator<Item = Result<(Option<Value>, Option<Value>)>>

Key may be None so that messages are partitioned using round-robin. For example append-only without primary_key (aka downstream_pk) set.Value may be None so that messages with same key are removed during log compaction. For example debezium tombstone event.