public class ClusterLinkInterceptor
extends java.lang.Object
implements org.apache.kafka.clients.ClientInterceptor, org.apache.kafka.common.Configurable
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
DEST_METRICS_GROUP |
static java.lang.String |
LINK_TAG |
Constructor and Description |
---|
ClusterLinkInterceptor() |
Modifier and Type | Method and Description |
---|---|
void |
configure(java.util.Map<java.lang.String,?> configs) |
void |
configureMetrics(org.apache.kafka.common.metrics.Metrics metrics,
org.apache.kafka.common.utils.Time time) |
org.apache.kafka.common.protocol.types.Struct |
parseResponse(java.nio.ByteBuffer responseBuffer,
org.apache.kafka.common.requests.ResponseHeader responseHeader,
org.apache.kafka.common.requests.RequestHeader requestHeader,
long responseTimeMs) |
org.apache.kafka.common.network.Send |
toSend(org.apache.kafka.common.requests.RequestHeader requestHeader,
org.apache.kafka.common.requests.AbstractRequest requestBody,
java.lang.String destination) |
public static final java.lang.String DEST_METRICS_GROUP
public static final java.lang.String LINK_TAG
public void configure(java.util.Map<java.lang.String,?> configs)
configure
in interface org.apache.kafka.common.Configurable
public void configureMetrics(org.apache.kafka.common.metrics.Metrics metrics, org.apache.kafka.common.utils.Time time)
configureMetrics
in interface org.apache.kafka.clients.ClientInterceptor
public org.apache.kafka.common.network.Send toSend(org.apache.kafka.common.requests.RequestHeader requestHeader, org.apache.kafka.common.requests.AbstractRequest requestBody, java.lang.String destination)
toSend
in interface org.apache.kafka.clients.ClientInterceptor
public org.apache.kafka.common.protocol.types.Struct parseResponse(java.nio.ByteBuffer responseBuffer, org.apache.kafka.common.requests.ResponseHeader responseHeader, org.apache.kafka.common.requests.RequestHeader requestHeader, long responseTimeMs)
parseResponse
in interface org.apache.kafka.clients.ClientInterceptor