Struct TransactionTopicConfig 

pub struct TransactionTopicConfig {
    pub topic_prefix: String,
    pub emit_begin: bool,
    pub emit_end: bool,
    pub enrich_events: bool,
    pub max_in_flight: usize,
}

Configuration for transaction topic emission.

Fields

topic_prefix: String

Topic prefix (e.g., “mydb” -> “mydb.transaction”)

emit_begin: bool

Whether to emit BEGIN events (default: true)

emit_end: bool

Whether to emit END events (default: true)

enrich_events: bool

Whether to enrich CDC events with transaction context (default: true)

max_in_flight: usize

Maximum in-flight transactions before warning

Implementations

impl TransactionTopicConfig

pub fn builder() -> TransactionTopicConfigBuilder

Create a builder for TransactionTopicConfig.

pub fn transaction_topic(&self) -> String

Get the transaction topic name.

Trait Implementations

impl Clone for TransactionTopicConfig

fn clone(&self) -> TransactionTopicConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TransactionTopicConfig

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

Formats the value using the given formatter.

impl Default for TransactionTopicConfig

fn default() -> Self

Returns the “default value” for a type.