public class MultiTenantRequestContext
extends org.apache.kafka.common.requests.RequestContext
Constructor and Description |
---|
MultiTenantRequestContext(org.apache.kafka.common.requests.RequestHeader header,
String connectionId,
InetAddress clientAddress,
io.confluent.kafka.multitenant.MultiTenantPrincipal principal,
org.apache.kafka.common.network.ListenerName listenerName,
org.apache.kafka.common.security.auth.SecurityProtocol securityProtocol,
org.apache.kafka.common.network.ClientInformation clientInformation,
org.apache.kafka.common.security.authenticator.PathAwareSniHostName sniHostName,
org.apache.kafka.common.utils.Time time,
org.apache.kafka.common.metrics.Metrics metrics,
TenantMetrics tenantMetrics,
MultiTenantInterceptorConfig config,
Optional<org.apache.kafka.server.link.ClusterLinkSourceMetrics> clusterLinkSourceMetrics,
boolean isPrivilegedListener,
Optional<org.apache.kafka.common.security.auth.KafkaPrincipalSerde> principalSerde) |
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.common.network.Send |
buildResponseSend(org.apache.kafka.common.requests.AbstractResponse body) |
org.apache.kafka.common.requests.AbstractResponse |
intercept(org.apache.kafka.common.requests.AbstractRequest request,
int throttleTimeMs) |
org.apache.kafka.common.requests.RequestAndSize |
parseRequest(ByteBuffer buffer) |
boolean |
shouldIntercept() |
Optional<String> |
tenantPrefix() |
apiVersion, buildResponseEnvelopePayload, clientAddress, clientId, correlationId, getClientAddress, getPrincipal, getPrincipalSerde, listenerName, principal, requestType, requestVersion, securityProtocol, sniHostName, toString
public MultiTenantRequestContext(org.apache.kafka.common.requests.RequestHeader header, String connectionId, InetAddress clientAddress, io.confluent.kafka.multitenant.MultiTenantPrincipal principal, org.apache.kafka.common.network.ListenerName listenerName, org.apache.kafka.common.security.auth.SecurityProtocol securityProtocol, org.apache.kafka.common.network.ClientInformation clientInformation, org.apache.kafka.common.security.authenticator.PathAwareSniHostName sniHostName, org.apache.kafka.common.utils.Time time, org.apache.kafka.common.metrics.Metrics metrics, TenantMetrics tenantMetrics, MultiTenantInterceptorConfig config, Optional<org.apache.kafka.server.link.ClusterLinkSourceMetrics> clusterLinkSourceMetrics, boolean isPrivilegedListener, Optional<org.apache.kafka.common.security.auth.KafkaPrincipalSerde> principalSerde)
public Optional<String> tenantPrefix()
tenantPrefix
in class org.apache.kafka.common.requests.RequestContext
public org.apache.kafka.common.requests.RequestAndSize parseRequest(ByteBuffer buffer)
parseRequest
in class org.apache.kafka.common.requests.RequestContext
public boolean shouldIntercept()
shouldIntercept
in class org.apache.kafka.common.requests.RequestContext
public org.apache.kafka.common.requests.AbstractResponse intercept(org.apache.kafka.common.requests.AbstractRequest request, int throttleTimeMs)
intercept
in class org.apache.kafka.common.requests.RequestContext
public org.apache.kafka.common.network.Send buildResponseSend(org.apache.kafka.common.requests.AbstractResponse body)
buildResponseSend
in class org.apache.kafka.common.requests.RequestContext