log_store::kafka

Module high_watermark_manager

Source

Structs§

HighWatermarkManager 🔒
HighWatermarkManager is responsible for periodically updating the high watermark (latest existing record offset) for each Kafka topic.