Package org.apache.kafka.server.authorizer

Interface AuthorizableRequestContext

@Evolving public interface AuthorizableRequestContext
Request context interface that provides data from request header as well as connection and authentication information to plugins.

  • Method Summary

    Modifier and Type
    Method
    Description
    InetAddress
    clientAddress()
    Returns client IP address from which request was sent.
    String
    clientId()
    Returns the client id from the request header.
    int
    correlationId()
    Returns the correlation id from the request header.
    String
    listenerName()
    Returns name of listener on which request was received.
    KafkaPrincipal
    principal()
    Returns authenticated principal for the connection on which request was received.
    int
    requestType()
    16-bit API key of the request from the request header.
    int
    requestVersion()
    Returns the request version from the request header.
    SecurityProtocol
    securityProtocol()
    Returns the security protocol for the listener on which request was received.

  • Method Details

    • listenerName

      String listenerName()
      Returns name of listener on which request was received.

    • securityProtocol

      SecurityProtocol securityProtocol()
      Returns the security protocol for the listener on which request was received.

    • principal

      KafkaPrincipal principal()
      Returns authenticated principal for the connection on which request was received.

    • clientAddress

      InetAddress clientAddress()
      Returns client IP address from which request was sent.

    • requestType

      int requestType()
      16-bit API key of the request from the request header. See https://kafka.apache.org/protocol#protocol_api_keys for request types.

    • requestVersion

      int requestVersion()
      Returns the request version from the request header.

    • clientId

      String clientId()
      Returns the client id from the request header.

    • correlationId

      int correlationId()
      Returns the correlation id from the request header.