Class ClusterLinkInterceptor

java.lang.Object

io.confluent.kafka.link.ClusterLinkInterceptor

All Implemented Interfaces:

org.apache.kafka.clients.ClientInterceptor, org.apache.kafka.common.Configurable

public class ClusterLinkInterceptor
extends Object
implements org.apache.kafka.clients.ClientInterceptor, org.apache.kafka.common.Configurable

Field Summary

Fields

Modifier and Type	Field	Description
static final String	DEST_METRICS_GROUP
static final String	SOURCE_METRICS_GROUP

Constructor Summary

Constructors

Constructor	Description
ClusterLinkInterceptor()

Method Summary

Modifier and Type	Method	Description
void	clearTenantContext()
void	configure(Map<String,?> configs)
void	configureMetrics(org.apache.kafka.common.metrics.Metrics metrics)
void	ensureConnectionAllowed(InetSocketAddress socketAddress)
org.apache.kafka.common.requests.AbstractResponse	parseResponse(ByteBuffer responseBuffer, org.apache.kafka.common.requests.RequestHeader requestHeader, long requestSendTimeMs, long responseReceiveTimeMs)
void	setTenantContext(String environmentId)
org.apache.kafka.common.network.Send	toSend(org.apache.kafka.common.requests.RequestHeader requestHeader, org.apache.kafka.common.requests.AbstractRequest requestBody, long requestSendTimeMs)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

DEST_METRICS_GROUP

public static final String DEST_METRICS_GROUP

See Also:

• Constant Field Values

SOURCE_METRICS_GROUP

public static final String SOURCE_METRICS_GROUP

See Also:

• Constant Field Values

Constructor Details

ClusterLinkInterceptor

public ClusterLinkInterceptor()

Method Details

configure

public void configure(Map<String,?> configs)

Specified by:

configure in interface org.apache.kafka.common.Configurable

configureMetrics

public void configureMetrics(org.apache.kafka.common.metrics.Metrics metrics)

Specified by:

configureMetrics in interface org.apache.kafka.clients.ClientInterceptor

ensureConnectionAllowed

public void ensureConnectionAllowed(InetSocketAddress socketAddress)
                             throws IOException

Specified by:

ensureConnectionAllowed in interface org.apache.kafka.clients.ClientInterceptor

Throws:

IOException

setTenantContext

public void setTenantContext(String environmentId)

Specified by:

setTenantContext in interface org.apache.kafka.clients.ClientInterceptor

clearTenantContext

public void clearTenantContext()

Specified by:

clearTenantContext in interface org.apache.kafka.clients.ClientInterceptor

toSend

public org.apache.kafka.common.network.Send toSend(org.apache.kafka.common.requests.RequestHeader requestHeader,
 org.apache.kafka.common.requests.AbstractRequest requestBody,
 long requestSendTimeMs)

Specified by:

toSend in interface org.apache.kafka.clients.ClientInterceptor

parseResponse

public org.apache.kafka.common.requests.AbstractResponse parseResponse(ByteBuffer responseBuffer,
 org.apache.kafka.common.requests.RequestHeader requestHeader,
 long requestSendTimeMs,
 long responseReceiveTimeMs)

Specified by:

parseResponse in interface org.apache.kafka.clients.ClientInterceptor