public class MultiTenantInterceptor
extends java.lang.Object
implements org.apache.kafka.server.interceptor.BrokerInterceptor
Constructor and Description |
---|
MultiTenantInterceptor() |
Modifier and Type | Method and Description |
---|---|
void |
configure(java.util.Map<java.lang.String,?> configs) |
org.apache.kafka.common.requests.RequestContext |
newContext(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.metrics.Metrics metrics) |
void |
onAuthenticatedConnection(java.lang.String connectionId,
java.net.InetAddress clientAddress,
org.apache.kafka.common.security.auth.KafkaPrincipal principal,
org.apache.kafka.common.metrics.Metrics metrics) |
void |
onAuthenticatedDisconnection(java.lang.String connectionId,
java.net.InetAddress clientAddress,
org.apache.kafka.common.security.auth.KafkaPrincipal principal,
org.apache.kafka.common.metrics.Metrics metrics) |
public void onAuthenticatedConnection(java.lang.String connectionId, java.net.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(java.lang.String connectionId, java.net.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(java.util.Map<java.lang.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, 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.metrics.Metrics metrics)
newContext
in interface org.apache.kafka.server.interceptor.BrokerInterceptor