kafka.security.auth

SimpleAclAuthorizer

class SimpleAclAuthorizer extends Authorizer with Logging

Linear Supertypes
Logging, Authorizer, Configurable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. SimpleAclAuthorizer
  2. Logging
  3. Authorizer
  4. Configurable
  5. AnyRef
  6. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new SimpleAclAuthorizer()

Value Members

  1. final def !=(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any
  3. final def ##(): Int

    Definition Classes
    AnyRef → Any
  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any
  6. object AclChangedNotificationHandler extends NotificationHandler

  7. object ZkStateChangeListener extends IZkStateListener

  8. def addAcls(acls: Set[Acl], resource: Resource): Unit

    add the acls to resource, this is an additive operation so existing acls will not be overwritten, instead these new acls will be added to existing acls.

    add the acls to resource, this is an additive operation so existing acls will not be overwritten, instead these new acls will be added to existing acls.

    acls

    set of acls to add to existing acls

    resource

    the resource to which these acls should be attached.

    Definition Classes
    SimpleAclAuthorizerAuthorizer
  9. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  10. def authorize(session: Session, operation: Operation, resource: Resource): Boolean

    session

    The session being authenticated.

    operation

    Type of operation client is trying to perform on resource.

    resource

    Resource the client is trying to access.

    returns

    Definition Classes
    SimpleAclAuthorizerAuthorizer
  11. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  12. def close(): Unit

    Closes this instance.

    Closes this instance.

    Definition Classes
    SimpleAclAuthorizerAuthorizer
  13. def configure(javaConfigs: Map[String, _]): Unit

    Guaranteed to be called before any authorize call is made.

    Guaranteed to be called before any authorize call is made.

    Definition Classes
    SimpleAclAuthorizer → Configurable
  14. def debug(msg: ⇒ String, e: ⇒ Throwable): Unit

    Definition Classes
    Logging
  15. def debug(e: ⇒ Throwable): Any

    Definition Classes
    Logging
  16. def debug(msg: ⇒ String): Unit

    Definition Classes
    Logging
  17. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  18. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  19. def error(msg: ⇒ String, e: ⇒ Throwable): Unit

    Definition Classes
    Logging
  20. def error(e: ⇒ Throwable): Any

    Definition Classes
    Logging
  21. def error(msg: ⇒ String): Unit

    Definition Classes
    Logging
  22. def fatal(msg: ⇒ String, e: ⇒ Throwable): Unit

    Definition Classes
    Logging
  23. def fatal(e: ⇒ Throwable): Any

    Definition Classes
    Logging
  24. def fatal(msg: ⇒ String): Unit

    Definition Classes
    Logging
  25. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  26. def getAcls(): Map[Resource, Set[Acl]]

    gets the map of resource to acls for all resources.

    gets the map of resource to acls for all resources.

    Definition Classes
    SimpleAclAuthorizerAuthorizer
  27. def getAcls(principal: KafkaPrincipal): Map[Resource, Set[Acl]]

    get the acls for this principal.

    get the acls for this principal.

    principal
    returns

    empty Map if no acls exist for this principal, otherwise a map of resource -> acls for the principal.

    Definition Classes
    SimpleAclAuthorizerAuthorizer
  28. def getAcls(resource: Resource): Set[Acl]

    get set of acls for this resource

    get set of acls for this resource

    resource
    returns

    empty set if no acls are found, otherwise the acls for the resource.

    Definition Classes
    SimpleAclAuthorizerAuthorizer
  29. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  30. def hashCode(): Int

    Definition Classes
    AnyRef → Any
  31. def info(msg: ⇒ String, e: ⇒ Throwable): Unit

    Definition Classes
    Logging
  32. def info(e: ⇒ Throwable): Any

    Definition Classes
    Logging
  33. def info(msg: ⇒ String): Unit

    Definition Classes
    Logging
  34. def isEmptyAclAndAuthorized(operation: Operation, resource: Resource, principal: KafkaPrincipal, host: String, acls: Set[Acl]): Boolean

  35. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  36. def isSuperUser(operation: Operation, resource: Resource, principal: KafkaPrincipal, host: String): Boolean

  37. var logIdent: String

    Attributes
    protected
    Definition Classes
    Logging
  38. lazy val logger: Logger

    Definition Classes
    Logging
  39. val loggerName: String

    Definition Classes
    Logging
  40. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  41. final def notify(): Unit

    Definition Classes
    AnyRef
  42. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  43. def removeAcls(resource: Resource): Boolean

    remove a resource along with all of its acls from acl store.

    remove a resource along with all of its acls from acl store.

    resource
    returns

    Definition Classes
    SimpleAclAuthorizerAuthorizer
  44. def removeAcls(aclsTobeRemoved: Set[Acl], resource: Resource): Boolean

    remove these acls from the resource.

    remove these acls from the resource.

    resource

    resource from which the acls should be removed.

    returns

    true if some acl got removed, false if no acl was removed.

    Definition Classes
    SimpleAclAuthorizerAuthorizer
  45. def swallow(action: ⇒ Unit): Unit

    Definition Classes
    Logging
  46. def swallowDebug(action: ⇒ Unit): Unit

    Definition Classes
    Logging
  47. def swallowError(action: ⇒ Unit): Unit

    Definition Classes
    Logging
  48. def swallowInfo(action: ⇒ Unit): Unit

    Definition Classes
    Logging
  49. def swallowTrace(action: ⇒ Unit): Unit

    Definition Classes
    Logging
  50. def swallowWarn(action: ⇒ Unit): Unit

    Definition Classes
    Logging
  51. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  52. def toResourcePath(resource: Resource): String

  53. def toString(): String

    Definition Classes
    AnyRef → Any
  54. def trace(msg: ⇒ String, e: ⇒ Throwable): Unit

    Definition Classes
    Logging
  55. def trace(e: ⇒ Throwable): Any

    Definition Classes
    Logging
  56. def trace(msg: ⇒ String): Unit

    Definition Classes
    Logging
  57. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  58. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  59. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  60. def warn(msg: ⇒ String, e: ⇒ Throwable): Unit

    Definition Classes
    Logging
  61. def warn(e: ⇒ Throwable): Any

    Definition Classes
    Logging
  62. def warn(msg: ⇒ String): Unit

    Definition Classes
    Logging

Inherited from Logging

Inherited from Authorizer

Inherited from Configurable

Inherited from AnyRef

Inherited from Any

Ungrouped