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.