Struct CheckpointSection 

pub struct CheckpointSection {
    pub interval: Duration,
    pub max_pending_batches: usize,
    pub drain_timeout: Duration,
    pub stalled_fail_after: Duration,
}

checkpoint: — watermark commit policy.

Fields

interval: Duration

How often committable watermarks are flushed to the source.

max_pending_batches: usize

Maximum unacknowledged batches per partition before that partition is paused (doubles as a backpressure trigger).

drain_timeout: Duration

Shutdown/rebalance drain budget. Must be comfortably below the pod’s terminationGracePeriodSeconds.

stalled_fail_after: Duration

A partition watermark stalled behind a failed batch for longer than this fails the pipeline. Failed batches only stall watermarks permanently (their data replays after restart), so this converts a permanent sink failure — a dropped table, revoked credentials — into a clean Failed exit and a restart instead of a process that runs on forever, consuming the source but committing nothing for that partition.

Trait Implementations

impl Debug for CheckpointSection

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

Formats the value using the given formatter.

impl Default for CheckpointSection

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for CheckpointSection

where CheckpointSection: Default,

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for CheckpointSection

fn eq(&self, other: &CheckpointSection) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for CheckpointSection