@InterfaceStability.Evolving public interface AuthorizableRequestContext
Modifier and Type | Method and 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.
|
boolean |
isProxyModeLocal() |
default long |
kafkaRequestId()
Unique ID assigned to each request
|
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.
|
default long |
sessionId()
Returns session Id
|
String listenerName()
SecurityProtocol securityProtocol()
KafkaPrincipal principal()
InetAddress clientAddress()
boolean isProxyModeLocal()
int requestType()
int requestVersion()
String clientId()
int correlationId()
default long kafkaRequestId()
default long sessionId()