Class ZkLedgerUnderreplicationManager

  • All Implemented Interfaces:
    java.lang.AutoCloseable, LedgerUnderreplicationManager

    public class ZkLedgerUnderreplicationManager
    extends java.lang.Object
    implements LedgerUnderreplicationManager
    ZooKeeper implementation of underreplication manager. This is implemented in a hierarchical fashion, so it'll work with FlatLedgerManagerFactory and HierarchicalLedgerManagerFactory.

    Layout is: /root/underreplication/ LAYOUT ledgers/(hierarchicalpath)/urL(ledgerId) locks/(ledgerId)

    The hierarchical path is created by splitting the ledger into 4 2byte segments which are represented in hexadecimal. e.g. For ledger id 0xcafebeef0000feed, the path is cafe/beef/0000/feed/