@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. |
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()
int requestType()
int requestVersion()
String clientId()
int correlationId()
default long kafkaRequestId()
default long sessionId()