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 Detail

      • 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.