Module admin_util 

Shared admin/IO helpers used by replicator engine tasks.

All functions return Result<_, String> and map client errors via .map_err(|e| e.to_string()) so callers stay wire-error-agnostic.

Functions

ensure_compacted_topic

Ensure a compacted topic exists with 1 partition and 1 replica.

ensure_topic

Ensure topic exists with the given parameters, treating an already-exists response as success.

read_all

Drain all records from topic from the earliest offset, returning (key, value) pairs in order.

read_last_value_for_key

Return the value bytes of the last record whose key equals key.