Interface AuthorizableRequestContext
Request context interface that provides data from request header as well as connection
and authentication information to plugins.
-
Method Summary
Modifier and TypeMethodDescriptionReturns client IP address from which request was sent.clientId()
Returns the client id from the request header.int
Returns the correlation id from the request header.Returns name of listener on which request was received.Returns authenticated principal for the connection on which request was received.int
16-bit API key of the request from the request header.int
Returns the request version from the request header.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.
-