pub const CHECKPOINT_TOPIC: &str = "__krabka_connect_offsets";
Compacted Kafka topic holding the most recent source offset per connector.