Constants§
- DEFAULT_
PARTITION 🔒 - The default partition.
- DELETE_
RECORDS_ 🔒TIMEOUT - The default timeout for deleting records.
Functions§
- delete_
records 🔒 - Deletes the records for the given topic.
- find_
pruneable_ 🔒entry_ id_ for_ topic - Finds the prunable entry id for the topic.
- get_
offsets_ 🔒for_ topic - Returns the earliest and latest offsets for the given topic.
- get_
partition_ 🔒client - Returns a partition client for the given topic.
- missing_
region_ 🔒ids - should_
trigger_ 🔒prune - Determines whether pruning should be triggered based on the current pruned entry id and the prunable entry id. Returns true if:
- update_
pruned_ 🔒entry_ id - Updates the pruned entry id for the given topic.