Skip to main content

Module watermarks

laminar_connectors::kafka

Module watermarks 

Source
Expand description

Kafka per-partition watermark tracking.

Structsยง

KafkaWatermarkTracker
Kafka-specific watermark tracker wrapping PartitionedWatermarkTracker.
WatermarkMetrics
Metrics for watermark tracking.