public class MultiTenantInterceptor extends Object implements org.apache.kafka.server.interceptor.BrokerInterceptor
Constructor and Description |
---|
MultiTenantInterceptor() |
MultiTenantInterceptor(org.apache.kafka.common.utils.Time time) |
Modifier and Type | Method and Description |
---|---|
void |
configure(Map<String,?> configs) |
org.apache.kafka.common.requests.RequestContext |
newContext(org.apache.kafka.common.requests.RequestHeader header,
String connectionId,
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.metrics.Metrics metrics,
org.apache.kafka.common.security.authenticator.PathAwareSniHostName sniHostName,
boolean isPrivilegedListener,
Optional<org.apache.kafka.common.security.auth.KafkaPrincipalSerde> principalSerde) |
void |
onAuthenticatedConnection(String connectionId,
InetAddress clientAddress,
org.apache.kafka.common.security.auth.KafkaPrincipal principal,
org.apache.kafka.common.metrics.Metrics metrics) |
void |
onAuthenticatedDisconnection(String connectionId,
InetAddress clientAddress,
org.apache.kafka.common.security.auth.KafkaPrincipal principal,
org.apache.kafka.common.metrics.Metrics metrics) |
public MultiTenantInterceptor()
public MultiTenantInterceptor(org.apache.kafka.common.utils.Time time)
public void onAuthenticatedConnection(String connectionId, InetAddress clientAddress, org.apache.kafka.common.security.auth.KafkaPrincipal principal, org.apache.kafka.common.metrics.Metrics metrics)
onAuthenticatedConnection
in interface org.apache.kafka.server.interceptor.BrokerInterceptor
public void onAuthenticatedDisconnection(String connectionId, InetAddress clientAddress, org.apache.kafka.common.security.auth.KafkaPrincipal principal, org.apache.kafka.common.metrics.Metrics metrics)
onAuthenticatedDisconnection
in interface org.apache.kafka.server.interceptor.BrokerInterceptor
public void configure(Map<String,?> configs)
configure
in interface org.apache.kafka.common.Configurable
public org.apache.kafka.common.requests.RequestContext newContext(org.apache.kafka.common.requests.RequestHeader header, String connectionId, 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.metrics.Metrics metrics, org.apache.kafka.common.security.authenticator.PathAwareSniHostName sniHostName, boolean isPrivilegedListener, Optional<org.apache.kafka.common.security.auth.KafkaPrincipalSerde> principalSerde)
newContext
in interface org.apache.kafka.server.interceptor.BrokerInterceptor