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