Struct SinkConnectorCapabilities 

pub struct SinkConnectorCapabilities {
    pub exactly_once: bool,
    pub idempotent: bool,
    pub upsert: bool,
    pub changelog: bool,
    pub two_phase_commit: bool,
    pub schema_evolution: bool,
    pub partitioned: bool,
    pub suggested_write_timeout: Duration,
}

Capabilities declared by a sink connector.

Fields

exactly_once: bool

Whether the sink supports exactly-once semantics via epochs.

idempotent: bool

Whether the sink supports idempotent writes.

upsert: bool

Whether the sink supports upsert (insert-or-update) writes.

changelog: bool

Whether the sink can handle changelog/retraction records.

two_phase_commit: bool

Whether the sink supports two-phase commit (pre-commit + commit).

schema_evolution: bool

Whether the sink supports schema evolution.

partitioned: bool

Whether the sink supports partitioned writes.

suggested_write_timeout: Duration

Default per-call write_batch I/O timeout. Users can override via the sink.write.timeout.ms connector property.

Implementations

impl SinkConnectorCapabilities

pub fn new(suggested_write_timeout: Duration) -> Self

All booleans default to false; flip via with_* below or by assigning the fields directly (they’re pub).

pub fn with_exactly_once(self) -> Self

Enable exactly-once semantics (requires epoch + 2PC impl).

pub fn with_idempotent(self) -> Self

Enable idempotent writes (safe re-delivery on retry).

pub fn with_upsert(self) -> Self

Enable upsert (key-based insert-or-update).

pub fn with_changelog(self) -> Self

Enable changelog/retraction records.

pub fn with_two_phase_commit(self) -> Self

Enable two-phase commit (pre_commit + commit_epoch).

pub fn with_schema_evolution(self) -> Self

Enable additive schema evolution.

pub fn with_partitioned(self) -> Self

Enable partitioned writes.

Trait Implementations

impl Clone for SinkConnectorCapabilities

fn clone(&self) -> SinkConnectorCapabilities

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SinkConnectorCapabilities

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

Formats the value using the given formatter.