Skip to content

Implement removal from Kafka (aka the journal)

Jérémy Bobbio (Lunar) requested to merge lunar/swh-alter:implement-removal-from-journal into main

Before implementing removal from Kafka, we first refactor RecoveryBundleCreator to use a callback for each objects written to the bundle. The Remover can then use it to register the SWHIDs that will be removed from storage, and keys that needs to be removed from the journal topics. Please review these two commits separately.

With these changes, the integration tests in swh-environment!294 (merged) pass.

Closes #3 (closed)

Edited by Jérémy Bobbio (Lunar)

Merge request reports