public class MultiTenantRequestContext
extends org.apache.kafka.common.requests.RequestContext
Constructor and Description |
---|
MultiTenantRequestContext(org.apache.kafka.common.requests.RequestHeader header,
java.lang.String connectionId,
java.net.InetAddress clientAddress,
org.apache.kafka.common.security.auth.KafkaPrincipal 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.utils.Time time,
org.apache.kafka.common.metrics.Metrics metrics,
TenantMetrics tenantMetrics,
TenantPartitionAssignor partitionAssignor,
short defaultReplicationFactor,
int defaultNumPartitions) |
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.common.network.Send |
buildResponse(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(java.nio.ByteBuffer buffer) |
boolean |
shouldIntercept() |
java.util.Optional<java.lang.String> |
tenantPrefix() |
public MultiTenantRequestContext(org.apache.kafka.common.requests.RequestHeader header, java.lang.String connectionId, java.net.InetAddress clientAddress, org.apache.kafka.common.security.auth.KafkaPrincipal 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.utils.Time time, org.apache.kafka.common.metrics.Metrics metrics, TenantMetrics tenantMetrics, TenantPartitionAssignor partitionAssignor, short defaultReplicationFactor, int defaultNumPartitions)
public java.util.Optional<java.lang.String> tenantPrefix()
tenantPrefix
in class org.apache.kafka.common.requests.RequestContext
public org.apache.kafka.common.requests.RequestAndSize parseRequest(java.nio.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 buildResponse(org.apache.kafka.common.requests.AbstractResponse body)
buildResponse
in class org.apache.kafka.common.requests.RequestContext