Interface AuthorizableRequestContext

@Public 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()
    Returns the 16-bit API key (request_api_key) from the request header.
    int
    requestVersion()
    Returns the 16-bit API version (request_api_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()
      Returns the 16-bit API key (request_api_key) from the request header.
      See Also:

    • requestVersion

      int requestVersion()
      Returns the 16-bit API version (request_api_version) from the request header.
      See Also:

    • clientId

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

    • correlationId

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