Class AclEnforcement

java.lang.Object
org.apache.storm.zookeeper.AclEnforcement

public class AclEnforcement extends Object
This is code intended to enforce ZK ACLs.
  • Constructor Details

    • AclEnforcement

      public AclEnforcement()
  • Method Details

    • verifyAcls

      public static void verifyAcls(Map<String,Object> conf, boolean fixUp) throws Exception
      Verify the ZK ACLs are correct and optionally fix them if needed.
      Parameters:
      conf - the cluster config.
      fixUp - true if we want to fix the ACLs else false.
      Throws:
      Exception - on any error.
    • main

      public static void main(String[] args) throws Exception
      Throws:
      Exception